如何正确使用threading.local()来传递值

Question

为什么这段代码可以工作:

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()

我们正在做这项工作，我们需要在线程中全局存储一些数据。我们不能改变Detail的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()有什么建议吗?

Answer 1

每次调用local()都会得到一个新的线程本地实例。如果你调用它两次，你就得到了两个不同的局部对象。

就像做

new Car().setColor(red)
new Car().getColor()

你的例子调用了local两次，所以你在处理两个不同的对象。

def main():
  proc = multiprocessing.Process(target = foo)
  proc.start()
def foo():
  local().stuff = 'happiness'
  bar()
def bar():
  print local().stuff

见https://docs.python.org/2/library/threading.html