python 和 ipython threading.activeCount()

Question

我有一个导入线程并使用 threading.activeCount() 的模块确定所有线程何时完成。我最初使用标准 python 解释器编写我的模块。在脚本中使用我的模块很好，但是在 ipython 中导入我的模块并调用依赖于 threading.activeCount() 的函数时。我的函数永远不会返回。

代码:

for dev in run_list:
   proc = threading.Thread(target=go, args=[dev])
   proc.start()

while threading.activeCount() > 1:
   time.sleep(1)

我注意到，当第一次使用标准解释器导入线程并调用 threading.activeCount() 时，只计算了 1 个线程:

>>> import threading
>>> threading.activeCount()
1
>>> threading.enumerate()
[<_MainThread(MainThread, started 140344324941568)>]

但是当使用 ipython 时，初始计数是 2:

In [1]: import threading

In [2]: threading.activeCount()
Out[2]: 2

In [3]: threading.enumerate()
Out[3]: 
[<_MainThread(MainThread, started 140674997614336)>,
 <HistorySavingThread(Thread-1, started 140674935068416)>]

这个模块被各种使用各种解释器的人使用，所以我想知道是否有更好的方法来处理这个问题(最好仍然使用线程)？

Answer 1

join你的线程而不是依赖 activeCount:

threads = []
for dev in run_list:
    proc = threading.Thread(target=go, args=[dev])
    proc.start()
    threads.append(proc)

for proc in threads:
    proc.join()