0

我想在解释器中使用原子操作在两个线程之间共享一个变量，如此处所述http://effbot.org/zone/thread-synchronization.htm。核心数据类型的简单赋值（单字节码操作）应该是线程安全的，因为 python < 3.2 中的 GIL。理论到此为止。以下代码可以在主模式或从模式（-m 或 -s）下运行。主模式确实通过 UDP 不断发送数据。从模式确实会创建一个线程来从 udp 端口​​读取数据并更新每个接收到的数据包上的变量。

示例代码确实在创建时将共享变量作为参数传递给线程。我也尝试过使用全局变量或将线程本地存储传递给线程。

结果总是一样的。在 read_time_master 线程内，变量被分配。但是在主线程中，共享变量的值没有更新。

#!/usr/bin/env python

import socket
import itertools
import multiprocessing
from optparse import OptionParser
from time import sleep

PORT = 1666

def read_time_master(sock, time_master):
   while True:
     time_master = float(sock.recvfrom(1024)[0])

def main():
    time_master = 0.0
    p = OptionParser()
    p.add_option('--master', '-m', action='store_true')
    p.add_option('--slave', '-s', action='store_true')
    options, arguments = p.parse_args()
    if options.master or options.slave:
        sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, 0)
    if options.master:
        sock.connect(('127.0.0.1', PORT))
    if options.slave:
        sock.bind(('0.0.0.0', PORT))
        recv_thread = multiprocessing.Process(target=read_time_master, args=(sock, time_master))
        recv_thread.start()

    for time in itertools.count():
        print time
        if options.slave:
            print "master: %f" % time_master # -> not updated from other thread
        if options.master:
            try:
                sock.send(str(time))
            except socket.error:
                pass
        sleep(1)

    if options.master or options.slave:
        sock.close()

if __name__ == '__main__':
    main()
4

2 回答 2

5

您正在使用multiprocessing, not threading，这对您的情况没有帮助。如果您threading.Thread用于创建后台工作人员，您可能global time_master只需在由后台操作控制的函数中进行调用即可获得所需的内容。因为您使用的是multiprocessing，而不是threading，您可能需要查看multiprocessing.Queue该类以查找可用于在进程之间来回传递信息或同步它们的容器。您还可以创建在进程之间共享的变量（所有这些都包含在Python 主页multiprocessing的文档/示例中

于 2012-11-27T22:20:21.417 回答
1

您可以使用共享内存，如此处http://docs.python.org/2/library/multiprocessing.html#sharing-state-between-processes所述。请记住在从共享空间读取之前等待该过程完成。

于 2012-11-27T22:43:42.873 回答