python threading:要运行的最大线程数

Question

假设我有类似的东西:

def worker(name):
    time.sleep(10)
    print name
    return

thrs = []
for i in range(1000):
    t1 = threading.Thread(target=worker, args=(i,))
    thrs.append(t1)

for t in thrs:
    t.start()

有没有办法指定并行运行多少个线程？在上面的例子中,所有1000将并行运行

Answer 1

这可以使用multiprocessing.dummy它来提供multiprocessingapi 的线程版本.

from multiprocessing.dummy import Pool

pool = Pool(10)
result = pool.map(worker, range(1000))

在python 3中,concurrent.futures.ThreadPoolExecutor通常提供更好的界面.