聲明：本文內(nèi)容全部轉(zhuǎn)載猿說python文章
在前面的文章中我們已經(jīng)介紹了很多關(guān)于python線程相關(guān)的知識點，比如線程互斥鎖Lock/線程事件Event/線程條件變量Condition等等，而今天給大家講解的是線程池ThreadPoolExecutor，可能很多小伙伴會疑惑，threading 模塊能創(chuàng)建線程，ThreadPoolExecutor 也能創(chuàng)建線程，兩者都有什么區(qū)別呢？
??眾所周知，程序中使用線程會提高運(yùn)行效率，雖然線程是計算機(jī)的最小單位，但是線程的創(chuàng)建和使用一樣會占用計算機(jī)資源和產(chǎn)生開銷，一旦創(chuàng)建成千上萬的線程，計算機(jī)一樣會死機(jī)！一個合理的程序永遠(yuǎn)都是以消耗最少的資源干最多的事，就像公司老板，永遠(yuǎn)都想以最少的錢，招最少的人，干最多的事！
一.線程池原理
??大家都使用過迅雷下載，當(dāng)同時下載1000個任務(wù)甚至更多的時候，就算開通vip同時下載的數(shù)量也只有8個。如果同時創(chuàng)建1000個線程，首先對計算器的開銷也很大，而且每次只運(yùn)行8個線程，需要不停的創(chuàng)建和銷毀，這樣會顯得很麻煩。
而使用線程池ThreadPoolExecutor就可以解決上面的問題，其實只需要8個線程就行了，每個線程各分配一個任務(wù)，剩下的任務(wù)排隊等待，當(dāng)某個線程完成了任務(wù)的時候，排隊任務(wù)就可以安排給這個線程繼續(xù)執(zhí)行，這就是所謂的線程池ThreadPoolExecutor原理！
線程池
二.線程池ThreadPoolExecutor函數(shù)介紹
1.ThreadPoolExecutor構(gòu)造實例的時候，傳入max_workers參數(shù)來設(shè)置線程池中最多能同時運(yùn)行的線程數(shù)目。
2.使用submit函數(shù)來提交線程需要執(zhí)行的任務(wù)（函數(shù)名和參數(shù)）到線程池中，并返回該任務(wù)的句柄（類似于文件、畫圖），注意submit()不是阻塞的，而是立即返回。
3.通過submit函數(shù)返回的任務(wù)句柄，能夠使用done()方法判斷該任務(wù)是否結(jié)束。下面的例子可以看出，由于任務(wù)有2s的延時，在task1提交后立刻判斷，task1還未完成，而在延時4s之后判斷，task1就完成了。
4.使用cancel()方法可以取消提交的任務(wù)，如果任務(wù)已經(jīng)在線程池中運(yùn)行了，就取消不了。這個例子中，線程池的大小設(shè)置為2，任務(wù)已經(jīng)在運(yùn)行了，所以取消失敗。如果改變線程池的大小為1，那么先提交的是task1，task2還在排隊等候，這是時候就可以成功取消。
5.使用result()方法可以獲取任務(wù)的返回值，注意：這個方法是阻塞的。
三.線程池ThreadPoolExecutor簡單使用
# !usr/bin/env python# -*- coding:utf-8 _*-"""
@Author:何以解憂
@Blog(個人博客地址): shuopython.com
@WeChat Official Account(微信公眾號)：猿說python
@Github:www.github.com
@File:python_threadpool.py
@Time:2019/11/29 1queue5:25
@Motto:不積跬步無以至千里，不積小流無以成江海，程序人生的精彩需要堅持不懈地積累！
"""fromconcurrent.futuresimportThreadPoolExecutorimporttime# 參數(shù)times用來模擬下載的時間defdown_video(times):time.sleep(times)print("down video {}s finished".format(times))returntimesexecutor=ThreadPoolExecutor(max_workers=2)# 通過submit函數(shù)提交執(zhí)行的函數(shù)到線程池中，submit函數(shù)立即返回，不阻塞task1=executor.submit(down_video,(3))task2=executor.submit(down_video,(2))# done方法用于判定某個任務(wù)是否完成print("任務(wù)1是否已經(jīng)完成：",task1.done())# cancel方法用于取消某個任務(wù),該任務(wù)沒有放入線程池中才能取消成功print("取消任務(wù)2：",task2.cancel())time.sleep(4)print("任務(wù)1是否已經(jīng)完成：",task1.done())# result方法可以獲取task的執(zhí)行結(jié)果print(task1.result())
??輸出結(jié)果：
任務(wù)1是否已經(jīng)完成：False取消任務(wù)2：Falsedown video2s finisheddown video3s finished任務(wù)1是否已經(jīng)完成：True3
??線程池的使用遠(yuǎn)不止如此，由于篇幅有限，關(guān)于線程池as_completed / map / wait 函數(shù)等我們留到下一篇文章繼續(xù)介紹~~~
關(guān)于線程池的阻塞和執(zhí)行順序相關(guān)介紹請參考：python 線程池ThreadPoolExecutor（下）
作者：猿說python
鏈接：http://www.itdecent.cn/p/68d44dd7e086
來源：簡書
