相关疑难解决方法(0)

有没有办法杀死一个线程?

是否可以在不设置/检查任何标志/信号量/等的情况下终止正在运行的线程?

python multithreading kill terminate

710
推荐指数
16
解决办法
71万
查看次数

如何使用带超时的concurrent.futures?

我试图使用concurrent.futures模块在python3.2中使用超时.但是当它超时时,它并没有真正停止执行.我尝试了两个线程和进程池执行程序,它们都没有停止任务,只有在完成后才会引发超时.那么有谁知道它是否有可能使这个工作?

import concurrent.futures
import time
import datetime

max_numbers = [10000000, 10000000, 10000000, 10000000, 10000000]

def run_loop(max_number):
    print("Started:", datetime.datetime.now(), max_number)
    last_number = 0;
    for i in range(1, max_number + 1):
        last_number = i * i
    return last_number

def main():
    with concurrent.futures.ProcessPoolExecutor(max_workers=len(max_numbers)) as executor:
        try:
            for future in concurrent.futures.as_completed(executor.map(run_loop, max_numbers, timeout=1), timeout=1):
                print(future.result(timeout=1))
        except concurrent.futures._base.TimeoutError:
            print("This took to long...")

if __name__ == '__main__':
    main()
Run Code Online (Sandbox Code Playgroud)

python concurrency timeout python-3.x

15
推荐指数
2
解决办法
1万
查看次数