python线程池的使用

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,否则返回False
print(task2.done())
time.sleep(4)
print(task1.done())
print(task2.done())
print(task1.result())      # 获取任务的返回值，注意：这个方法会阻塞主线程，等待这个任务执行完得到结果
print(task2.result())


if __name__ == ‘__main__‘:
    pass