使用current.futures使用超时限制函数执行

问题描述

在代码中：

import concurrent.futures
import time


def f():
    time.sleep(5)


ids = [1,2]

with concurrent.futures.ThreadPoolExecutor(max_workers=len(ids)) as executor:
    futures = [executor.submit(f) for _ in ids]

    for future in concurrent.futures.as_completed(futures):
        future.result()

如何限制功能 f 的执行时间为2秒（我不想等待超过2秒）？我尝试了 as_completed（futures，timeout = 2）和 future.future（timeout = 2），但没有任何效果。

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）