如何解决使用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 举报,一经查实,本站将立刻删除。