如何将线程对象传递给 ThreadPoolExecutor？

Question

concurrent.futures.ThreadPoolExecutor 用于将 函数 传递给带有executor.submit(my_function) 的执行器，如下所示：

def my_function():
    print("Hello, world!")

with concurrent.futures.ThreadPoolExecutor(max_workers=50) as executor:
    for t in range(50):
        executor.submit(my_function())

但是有没有办法传递一个线程对象来代替？我有一个线程子类，我想与执行器一起使用。

Answer 1

试试这样的：

import concurrent.futures

def my_function(num_time):
    print(f"Hello, world {num_time} times")

with concurrent.futures.ThreadPoolExecutor() as executor:
    
    results = [executor.submit(my_function,i) for i in range(50)]
  

    for f in concurrent.futures.as_completed(results):
        print(f.result())