Python中线程之间的通信（不使用全局变量）

假设我们有一个主线程，它为测试模块启动两个线程 - “test_a”和“test_b”。 无论测试模块执行完毕还是遇到任何错误、警告或者想要更新某些其他信息，两个测试模块线程都会保持其状态。

主线程如何访问这些信息并采取相应的行动。 例如，如果“test_a”引发错误标志；在出现错误之前，“主要”如何知道并停止其余测试？

一种方法是使用全局变量，但这会变得非常难看......很快。

显而易见的解决方案是通过在构造函数/启动时将其传递给线程对象/函数来共享某种可变变量。

执行此操作的简洁方法是构建一个具有适当实例属性的类。如果您使用的是threading.Thread subclass https://docs.python.org/2/library/threading.html#thread-objects，您通常可以使用子类本身作为粘贴这些属性的地方，而不仅仅是一个线程函数。但我会用一个来展示它list只是因为它更短：

def test_a_func(thread_state):
    # ...
    thread_state[0] = my_error_state
    # ...

def main_thread():
    test_states = [None]
    test_a = threading.Thread(target=test_a_func, args=(test_states,))
    test_a.start()

您还可以（并且通常想要）打包Lock or Condition进入可变状态对象，这样你就可以在之间正确同步main_thread and test_a.

（另一种选择是使用queue.Queue, an os.pipe等来传递信息，但您仍然需要将该队列或管道传递给子线程 - 您的操作方式与上面完全相同。）

但是，值得考虑您是否真的需要这样做。如果你想到test_a and test_b作为“作业”，而不是“线程函数”，您可以在池上执行这些作业，并让池处理返回的结果或错误。

例如：

try:
    with concurrent.futures.ThreadPoolExecutor(workers=2) as executor:
        tests = [executor.submit(job) for job in (test_a, test_b)]
        for test in concurrent.futures.as_completed(tests):
            result = test.result()
except Exception as e:
    # do stuff

现在，如果test_a函数引发异常，主线程将得到该异常——并且，因为这意味着退出with阻塞，所有其他作业都被取消并丢弃，并且工作线程关闭。

如果您使用的是 2.5-3.1，则没有concurrent.futures内置，但您可以安装PyPI 的向后移植 https://pypi.python.org/pypi/futures，或者你可以重写一些东西multiprocessing.dummy.Pool. (It's slightly这样会更复杂，因为您必须创建一系列作业并调用map_async返回一个迭代器AsyncResult对象……但实际上这仍然很简单。）