# example1.pyfrom concurrent.futures import ThreadPoolExecutorimport timedef return_future_result(message): time.sleep(2) return messagepool = ThreadPoolExecutor(max_workers=2) # 創(chuàng)建一個最大可容納2個task的線程池future1 = pool.submit(return_future_result, ("hello")) # 往線程池里面加入一個taskfuture2 = pool.submit(return_future_result, ("world")) # 往線程池里面加入一個taskprint(future1.done()) # 判斷task1是否結束time.sleep(3)print(future2.done()) # 判斷task2是否結束print(future1.result()) # 查看task1返回的結果print(future2.result()) # 查看task2返回的結果

我們根據運行結果來分析一下。我們使用 submit 方法來往線程池中加入一個task，submit返回一個 Future對象 ，對于Future對象可以簡單地理解為一個在未來完成的操作。在第一個print語句中很明顯因為time.sleep(2)的原因我們的future1沒有完成，因為我們使用time.sleep(3)暫停了主線程，所以到第二個print語句的時候我們線程池里的任務都已經全部結束。

ziwenxie :: ~ » python example1.pyFalseTruehelloworld# 在上述程序執(zhí)行的過程中，通過ps命令我們可以看到三個線程同時在后臺運行ziwenxie :: ~ » ps -eLf | grep pythonziwenxie      8361  7557  8361  3    3 19:45 pts/0    00:00:00 python example1.pyziwenxie      8361  7557  8362  0
 2/8   首頁 上一頁 1 2 3 4 5 6 下一頁 尾頁