为什么这段代码能工作:
data = local()
def main():
proc = multiprocessing.Process(target = foo)
proc.start()
def foo():
data.stuff = 'happiness'
bar()
def bar():
print data.stuff
但是这个代码不起作用吗?
def main():
proc = multiprocessing.Process(target = foo)
proc.start()
def foo():
local().stuff = 'happiness'
bar()
def bar():
print local().stuff
我们的代码分为几个模块,它有多个线程。我们需要将值传递给需要在所有这些模块中保持不变的线程。
例如:
我们实例化了一堆工作。
# inside module_name_a.py
work = Work(a, b, c)
proc = multiprocessing.Process(target = work.do_this)
proc.start()
我们正在做这项工作,我们需要在线程中全局存储一些数据。我们不能改变细节的API。
# inside work_module_b.py
class Work():
.
.
.
def do_this():
detail = Detail(x, y, z)
local().stuff = 'important'
detail.handle_this()
我们需要handle_this()
的主体来“查看”threading.local()
中的值
# inside detail_module_b.py
class Detail():
.
.
.
def do_this():
detail = Detail(x, y, z)
local().stuff = 'important'
detail.handle_this()
对于正确使用threading.local()有什么建议吗?
发布于 2015-08-03 14:33:04
每次调用local()时,都会得到一个新的线程本地实例。如果您调用它两次,则有两个不同的本地对象。
就像在做
new Car().setColor(red)
new Car().getColor()
您的示例调用本地两次,因此处理两个不同的对象。
def main():
proc = multiprocessing.Process(target = foo)
proc.start()
def foo():
local().stuff = 'happiness'
bar()
def bar():
print local().stuff
https://stackoverflow.com/questions/31789099
复制相似问题