向 Python 线程发送参数会阻塞其他线程

Question

考虑将参数传递给 Python 线程的测试应用程序：

#!/usr/bin/python3

from pprint import pprint
import signal
import sys
import threading


class CallThreads(threading.Thread):

    def __init__(self, target, *args):
        self._target = target
        threading.Thread.__init__(self)
        target(*args)

def main(argv):
    phrases = ['hello', 'goodbye']
    num = 0

    for phrase in phrases:
        num += 1
        thread_handler = CallThreads(someFunction, phrase, num)
        thread_handler.daemon = True
        thread_handler.start()

    return True


def someFunction(a, b):
    print("Hi: "+str(a)+" and "+str(b))
    return True


def signal_handler(signal, frame):
    print(["Got SIGINT!"])
    sys.exit(0)


if __name__ == '__main__':
    signal.signal(signal.SIGINT, signal_handler)
    main(sys.argv)

在当前状态下，for phrase in phrases 循环似乎正在等待线程完成，然后再启动另一个线程。也就是说，如果someFunction() 需要很长时间才能完成，那么直到前一个线程返回后，才会启动下一个线程。为什么会这样？如何在仍然向线程发送参数的同时解决它？

编辑： 我尝试在构造函数中将args 数组保存在self._args 中，然后在def run (self): 中调用self._target(*self._args) 或self._target(self._args)。这实际上适用于 Python 2，但不适用于 Python 3。我该怎么办？

编辑： 似乎问题在于，在 Python 3 中，run 方法无法访问私有变量。即对于如下改进代码：

def __init__(self, target, *args):
    self._args = args
    threading.Thread.__init__(self)

def run(self):
    someFunction(*self._args)

注意以下输出：

Exception in thread Thread-1:
Traceback (most recent call last):
  File "/usr/lib/python3.3/threading.py", line 639, in _bootstrap_inner
    self.run()
  File "./test.py", line 19, in run
    someFunction(*self._args)
TypeError: someFunction() missing 2 required positional arguments: 'a' and 'b'

在run() 方法中添加pprint(self._args) 确实表明返回的元组是空的。但是，将变量更改为非私有有效！以下代码运行良好：

def __init__(self, target, *args):
    self.target = target
    self.args = args
    threading.Thread.__init__(self)

def run(self):
    self.target(*self.args)

因此，我可以在 Python 3 中将应用程序与公共变量一起使用。但是，有什么方法可以在 CallThreads 类中使用私有变量，就像在 Python 2 中一样？

谢谢！

Answer 1

问题是你在CallThreads的构造函数上调用了target(args)。

因此，在CallThreads.__init__() 完成之前，以下调用会阻塞：

thread_handler = CallThreads(someFunction, phrase, num)

更新： 一种可能是：

class CallThreads(threading.Thread):

    def __init__(self, *args):
        self._args   = args
        threading.Thread.__init__(self)

    def run(self):
        someFunction(*self._args)