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

Question

concurrent.futures.ThreadPoolExecutor 通过 传递 function 到执行器 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())