Python學(xué)習(xí)筆記之線程
1.自定義進(jìn)程
自定義進(jìn)程類,繼承Process類,重寫run方法(重寫Process的run方法)。
from multiprocessing import Process import time import os class MyProcess(Process): def __init__(self, name): ##重寫,需要__init__,也添加了新的參數(shù)。 ##Process.__init__(self) 不可以省略,否則報(bào)錯(cuò):AttributeError:'XXXX'object has no attribute '_colsed' Process.__init__(self) self.name = name def run(self): print("子進(jìn)程(%s-%s)啟動(dòng)" % (self.name, os.getpid())) time.sleep(3) print("子進(jìn)程(%s-%s)結(jié)束" % (self.name, os.getpid())) if __name__ == '__main__': print("父進(jìn)程啟動(dòng)") p = MyProcess("Ail") # 自動(dòng)調(diào)用MyProcess的run()方法 p.start() p.join() print("父進(jìn)程結(jié)束")
# 輸出結(jié)果
父進(jìn)程啟動(dòng)
子進(jìn)程(Ail-38512)啟動(dòng)
子進(jìn)程(Ail-38512)結(jié)束
父進(jìn)程結(jié)束
2.進(jìn)程與線程
多進(jìn)程適合在CPU密集型操作(CPU操作指令比較多,如科學(xué)計(jì)算、位數(shù)多的浮點(diǎn)計(jì)算);
多線程適合在IO密集型操作(讀寫數(shù)據(jù)操作比較多的,比如爬蟲、文件上傳、下載)
線程是并發(fā),進(jìn)程是并行:進(jìn)程之間互相獨(dú)立,是系統(tǒng)分配資源的最小單位,同一個(gè)進(jìn)程中的所有線程共享資源。
進(jìn)程:一個(gè)運(yùn)行的程序或代碼就是一個(gè)進(jìn)程,一個(gè)沒有運(yùn)行的代碼叫程序。進(jìn)程是系統(tǒng)進(jìn)行資源分配的最小單位,進(jìn)程擁有自己的內(nèi)存空間,所以,進(jìn)程間數(shù)據(jù)不共享,開銷大。
進(jìn)程是程序的一次動(dòng)態(tài)執(zhí)行過程。每個(gè)進(jìn)程都擁有自己的地址空間、內(nèi)存、數(shù)據(jù)棧以及其它用于跟蹤執(zhí)行的輔助數(shù)據(jù)。操作系統(tǒng)負(fù)責(zé)其上所有進(jìn)程的執(zhí)行,操作系統(tǒng)會(huì)為這些進(jìn)程合理地分配執(zhí)行時(shí)間。
線程:調(diào)度執(zhí)行的最小單位,也叫執(zhí)行路徑,不能獨(dú)立存在,依賴進(jìn)程的存在而存在,一個(gè)進(jìn)程至少有一個(gè)線程,叫做主線程,多個(gè)線程共享內(nèi)存(數(shù)據(jù)共享和全局變量),因此提升程序的運(yùn)行效率。
線程是操作系統(tǒng)能夠進(jìn)行運(yùn)算調(diào)度的最小單位,它被包含在進(jìn)程之中,是進(jìn)程中的實(shí)際運(yùn)作單位。一條線程指的是進(jìn)程中一個(gè)單一順序的控制流,一個(gè)進(jìn)程中可以并發(fā)多個(gè)線程,每條線程并行執(zhí)行不同的任務(wù)。一個(gè)線程是一個(gè)execution context(執(zhí)行上下文),即一個(gè)CPU執(zhí)行時(shí)所需要的一串指令。
主線程:主線程就是創(chuàng)建線程進(jìn)程中產(chǎn)生的第一個(gè)線程,也就是main函數(shù)對(duì)應(yīng)的線程。
協(xié)程:用戶態(tài)的輕量級(jí)線程,調(diào)度由用戶控制,擁有自己的寄存器上下文和棧,切換基本沒有內(nèi)核切換的開銷,切換靈活。
進(jìn)程和線程的關(guān)系
3.多線程
操作系統(tǒng)通過給不同的線程分配時(shí)間片(CPU運(yùn)行時(shí)長(zhǎng))來調(diào)度線程,當(dāng)CPU執(zhí)行完一個(gè)線程的時(shí)間片后就會(huì)快速切換到下一個(gè)線程,時(shí)間片很短而且切換速度很快,以至于用戶根本察覺不到。多個(gè)線程根據(jù)分配的時(shí)間片輪流被CPU執(zhí)行,如今絕大多數(shù)計(jì)算機(jī)的CPU都是多核的,多個(gè)線程在操作系統(tǒng)的調(diào)度下,能夠被多個(gè)CPU并行執(zhí)行,程序的執(zhí)行速度和CPU的利用效率大大提升。絕大對(duì)數(shù)主流的編程語(yǔ)言都能很好地支持多線程,然而,Python由于GIL鎖無法實(shí)現(xiàn)真正的多線程。
內(nèi)存中的線程
4.Thread類方法
(1)start()
--開始執(zhí)行該線程;
(2)run()
--定義線程的方法(開發(fā)者可以在子類中重寫);標(biāo)準(zhǔn)的 run() 方法會(huì)對(duì)作為 target 參數(shù)傳遞給該對(duì)象構(gòu)造器的可調(diào)用對(duì)象(如果存在)發(fā)起調(diào)用,并附帶從 args 和 kwargs 參數(shù)分別獲取的位置和關(guān)鍵字參數(shù)。
(3)join(timeout=None)
--直至啟動(dòng)的線程終止之前一直掛起;除非給出了timeout(單位秒),否則一直被阻塞;因?yàn)?join() 總是返回 None ,所以要在 join() 后調(diào)用 is_alive() 才能判斷是否發(fā)生超時(shí) -- 如果線程仍然存活,則 join() 超時(shí)。一個(gè)線程可以被 join() 很多次。如果嘗試加入當(dāng)前線程會(huì)導(dǎo)致死鎖, join() 會(huì)引起 RuntimeError 異常。如果嘗試 join() 一個(gè)尚未開始的線程,也會(huì)拋出相同的異常。
(4)is_alive()
--布爾值,表示這個(gè)線程是否還存活;當(dāng) run() 方法剛開始直到 run() 方法剛結(jié)束,這個(gè)方法返回 True 。
(5)threading.current_thread()--
返回當(dāng)前對(duì)應(yīng)調(diào)用者的控制線程的 Thread 對(duì)象。例如,獲取當(dāng)前線程的名字,可以是current_thread().name
。
5.多線程與多進(jìn)程小Case
from threading import Thread from multiprocessing import Process import os def work(): print('hello,',os.getpid()) if __name__ == '__main__': # 在主進(jìn)程下開啟多個(gè)線程,每個(gè)線程都跟主進(jìn)程的pid一樣 t1 = Thread(target=work) # 開啟一個(gè)線程 t2 = Thread(target=work) # 開啟兩個(gè)線程 t1.start() ##start()--It must be called at most once per thread object.It arranges for the object's run() method to be ## invoked in a separate thread of control.This method will raise a RuntimeError if called more than once on the ## same thread object. t2.start() print('主線程/主進(jìn)程pid', os.getpid()) # 開多個(gè)進(jìn)程,每個(gè)進(jìn)程都有不同的pid p1 = Process(target=work) p2 = Process(target=work) p1.start() p2.start() print('主線程/主進(jìn)程pid',os.getpid())
6.Thread 的生命周期
線程的狀態(tài)包括:創(chuàng)建、就緒、運(yùn)行、阻塞、結(jié)束。
(1)創(chuàng)建對(duì)象時(shí),代表 Thread 內(nèi)部被初始化;
(2) 調(diào)用 start() 方法后,thread 會(huì)開始進(jìn)入隊(duì)列準(zhǔn)備運(yùn)行,在未獲得CPU、內(nèi)存資源前,稱為就緒狀態(tài);輪詢獲取資源,進(jìn)入運(yùn)行狀態(tài);如果遇到sleep,則是進(jìn)入阻塞狀態(tài);
(3) thread 代碼正常運(yùn)行結(jié)束或者是遇到異常,線程會(huì)終止。
7.自定義線程
(1)定義一個(gè)類,繼承Thread;
(2)重寫__init__ 和 run();
(3)創(chuàng)建線程類對(duì)象;
(4)啟動(dòng)線程。
import time import threading class MyThread(threading.Thread): def __init__(self,num): super().__init__() ###或者是Thread.__init__() self.num = num def run(self): print('線程名稱:', threading.current_thread().getName(), '參數(shù):', self.num, '開始時(shí)間:', time.strftime('%Y-%m-%d %H:%M:%S')) if __name__ == '__main__': print('主線程開始:',time.strftime('%Y-%m-%d %H:%M:%S')) t1 = MyThread(1) t2 = MyThread(2) t1.start() t2.start() t1.join() t2.join() print('主線程結(jié)束:', time.strftime('%Y-%m-%d %H:%M:%S'))
8.線程共享數(shù)據(jù)與GIL(全局解釋器鎖)
如果是全局變量,則每個(gè)線程是共享的;
GIL鎖:可以用籃球比賽的場(chǎng)景來模擬,把籃球場(chǎng)看作是CPU,一場(chǎng)籃球比賽看作是一個(gè)線程,如果只有一個(gè)籃球場(chǎng),多場(chǎng)比賽就要排隊(duì)進(jìn)行,類似于一個(gè)簡(jiǎn)單的單核多線程的程序;如果由多塊籃球場(chǎng),多場(chǎng)比賽同時(shí)進(jìn)行,就是一個(gè)簡(jiǎn)單的多核多線程的程序。然而,Python有著特別的規(guī)定:每場(chǎng)比賽必須要在裁判的監(jiān)督之下才允許進(jìn)行,而裁判只有一個(gè)。這樣不管你有幾塊籃球場(chǎng),同一時(shí)間只允許有一個(gè)場(chǎng)地進(jìn)行比賽,其它場(chǎng)地都將被閑置,其它比賽都只能等待。
9.GIL 和 Lock
GIL保證同一時(shí)間內(nèi)一個(gè)進(jìn)程可以有多個(gè)線程,但只有一個(gè)線程在執(zhí)行;鎖的目的是為了保護(hù)共享的數(shù)據(jù),同一時(shí)間只能有一個(gè)線程來修改共享的數(shù)據(jù)。
類為threading.Lock
它有兩個(gè)基本方法, acquire() 和 release() 。
當(dāng)狀態(tài)為非鎖定時(shí), acquire() 將狀態(tài)改為 鎖定 并立即返回。當(dāng)狀態(tài)是鎖定時(shí), acquire() 將阻塞至其他線程調(diào)用 release() 將其改為非鎖定狀態(tài),然后 acquire() 調(diào)用重置其為鎖定狀態(tài)并返回。
release() 只在鎖定狀態(tài)下調(diào)用; 它將狀態(tài)改為非鎖定并立即返回。如果嘗試釋放一個(gè)非鎖定的鎖,則會(huì)引發(fā) RuntimeError 異常。
Caese 如下:
from threading import Thread from threading import Lock import time number = 0 def task(lock): global number lock.acquire() ##持有鎖 for i in range(100000) number += 1 lock.release() ##釋放鎖 if __name__ == '__main__': lock=Lock() t1 = Thread(target=task,args=(lock,)) t2 = Thread(target=task,args=(lock,)) t3 = Thread(target=task,args=(lock,)) t1.start() t2.start() t3.start() t1.join() t2.join() t3.join() print('number:',number)
10.線程的信號(hào)量
class threading.Semaphore([values])
values是一個(gè)內(nèi)部計(jì)數(shù),values默認(rèn)是1,如果小于0,則會(huì)拋出 ValueError 異常,可以用于控制線程數(shù)并發(fā)數(shù)。
信號(hào)量的實(shí)現(xiàn)方式:
s=Semaphore(?)
在內(nèi)部有一個(gè)counter計(jì)數(shù)器,counter的值就是同一時(shí)間可以開啟線程的個(gè)數(shù)。每當(dāng)我們s.acquire()一次,計(jì)數(shù)器就進(jìn)行減1處理,每當(dāng)我們s.release()一次,計(jì)數(shù)器就會(huì)進(jìn)行加1處理,當(dāng)計(jì)數(shù)器為0的時(shí)候,其它的線程就處于等待的狀態(tài)。
程序添加一個(gè)計(jì)數(shù)器功能(信號(hào)量),限制一個(gè)時(shí)間點(diǎn)內(nèi)的線程數(shù)量,防止程序崩潰或其它異常。
Case
import time import threading s=threading.Semaphore(5) #添加一個(gè)計(jì)數(shù)器 def task(): s.acquire() #計(jì)數(shù)器獲得鎖 time.sleep(2) #程序休眠2秒 print("The task run at ",time.ctime()) s.release() #計(jì)數(shù)器釋放鎖 for i in range(40): t1=threading.Thread(target=task,args=()) #創(chuàng)建線程 t1.start() #啟動(dòng)線程
也可以使用with操作,替代acquire ()和release(),上面的代碼調(diào)整如下:
import time import threading s=threading.Semaphore(5) #添加一個(gè)計(jì)數(shù)器 def task(): with s: ## 類似打開文件的with操作 ##s.acquire() #計(jì)數(shù)器獲得鎖 time.sleep(2) #程序休眠2秒 print("The task run at ",time.ctime()) ##s.release() #計(jì)數(shù)器釋放鎖 for i in range(40): t1=threading.Thread(target=task,args=()) #創(chuàng)建線程 t1.start() #啟動(dòng)線程
建議使用with。
總結(jié)
本篇文章就到這里了,希望能夠給你帶來幫助,也希望您能夠多多關(guān)注腳本之家的更多內(nèi)容!
相關(guān)文章
Python requests接口測(cè)試實(shí)現(xiàn)代碼
這篇文章主要介紹了Python requests接口測(cè)試實(shí)現(xiàn)代碼,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-09-09Python中Parser的超詳細(xì)用法實(shí)例
Parser模塊為Python的內(nèi)部解析器和字節(jié)碼編譯器提供了一個(gè)接口,該接口的主要目的是允許Python代碼編輯Python表達(dá)式的分析樹并從中創(chuàng)建可執(zhí)行代碼,這篇文章主要給大家介紹了關(guān)于Python中Parser超詳細(xì)用法的相關(guān)資料,需要的朋友可以參考下2022-07-07python print輸出延時(shí),讓其立刻輸出的方法
今天小編就為大家分享一篇python print輸出延時(shí),讓其立刻輸出的方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2019-01-01詳解Numpy中的數(shù)組拼接、合并操作(concatenate, append, stack, hstack, vstac
這篇文章主要介紹了詳解Numpy中的數(shù)組拼接、合并操作(concatenate, append, stack, hstack, vstack, r_, c_等),具有一定的參考價(jià)值,感興趣的小伙伴們可以參考一下2019-05-05基于python進(jìn)行桶排序與基數(shù)排序的總結(jié)
今天小編就為大家分享一篇基于python進(jìn)行桶排序與基數(shù)排序的總結(jié),具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2018-05-05Python基于FTP模塊實(shí)現(xiàn)ftp文件上傳操作示例
這篇文章主要介紹了Python基于FTP模塊實(shí)現(xiàn)ftp文件上傳操作,結(jié)合實(shí)例形式分析了Python引入ftp模塊及相關(guān)設(shè)置、文件傳輸?shù)炔僮骷记?需要的朋友可以參考下2018-04-04