from concurrent.futures import ThreadPoolExecutor
import time
def get_html(times):
time.sleep(times)
print(‘{}, finished‘.format(times))
return times
executor = ThreadPoolExecutor(max_workers=2); #创建线程池
task1 = executor.submit(get_html, 3) # 提交任务
task2 = executor.submit(get_html, 2)
print(task1.done()) # 查询任务状态,完成返回True,否则返回Falseprint(task2.done())
time.sleep(4)
print(task1.done())
print(task2.done())
print(task1.result()) # 获取任务的返回值,注意:这个方法会阻塞主线程,等待这个任务执行完得到结果print(task2.result())
if__name__ == ‘__main__‘:
pass
原文:https://www.cnblogs.com/liuxuelin/p/14707704.html
【说明】:本文章由站长整理发布,文章内容不代表本站观点,如文中有侵权行为,请与本站客服联系(QQ:254677821)!