1. 程式人生 > >python 執行緒(建立2種方式,守護程序,鎖,死鎖,遞迴鎖,GIL鎖,其他方式)

python 執行緒(建立2種方式,守護程序,鎖,死鎖,遞迴鎖,GIL鎖,其他方式)

###############總結############

執行緒建立的2種方式(重點)

程序:資源分配單位    執行緒:cpu執行單位(實體)

執行緒的建立和銷燬的開銷特別小

執行緒之間資源共享,是同一個程序中的資源共享,會涉及到安全問題,所以需要加鎖解決

:犧牲了效率,保證了資料安全(重點)

死鎖現象:出現在巢狀的時候,雙方互相搶對方已經拿到的鎖,導致雙方互相等待(重點)

遞迴鎖: 解決了死鎖現象(重點)

  rlock 首先本身就是個互斥鎖,維護了一個計數器,每次acquire+1,release就-1,當計數器為0的時候,大家才會搶這個鎖

守護執行緒:

  守護執行緒:等待所有非守護執行緒結束才結束

  守護程序: 主程序執行程式碼結束,守護程序會隨之結束

GIL鎖:

 

###第一種
from
threading import Thread def f1(n): print(n) if __name__ == '__main__': t1=Thread(target=f1,args=(1,)) t1.start() ###第二種 class mythread(Thread): def __init__(self,name): super().__init__
() self.name=name def run(self): print('hellow'+self.name) if __name__ == '__main__': t=mythread('alex') t.start() print('主執行緒結束')

###檢視執行緒的程序id

import os
from  threading import Thread
def f1(n):
    print('1號',os.getpid())
    print('%s號'%n)
def f2(n):
    print
('2號',os.getpid()) print('%s'%n) if __name__ == '__main__': t1=Thread(target=f1,args=(1,)) t2=Thread(target=f2,args=(2,)) t1.start() t2.start() print('主程序id',os.getpid()) ############ 執行緒ID是一樣的

###驗證執行緒是資料共享的

import os
import time
from threading import Thread
num=100
def f1(n):
    global num
    num=3
    print('子執行緒num',num)
if __name__ == '__main__':
    t=Thread(target=f1,args=(1,))
    t.start()
    t.join()#主程序等待子程序執行完才繼續執行
    print('主程序的num',num)
###################

子執行緒num 3
主程序的num 3

###多程序效率對比

import time
from threading import Thread
from multiprocessing import Process
def f1():
    for i in range(5):
        i=i+i
if __name__ == '__main__':
    t_s_time=time.time()
    t_list=[]
    # 檢視一下20個執行緒執行20個任務的執行時間
    for i in range(20):
        t=Thread(target=f1,)
        t.start()
        t_list.append(t)
    [tt.join() for tt in t_list]
    t_e_time=time.time()
    t_dif_time=t_e_time-t_s_time
    # print(t_dif_time)
    #檢視一個20個程序執行的任務時間
##########################################
    p_s_time=time.time()
    p_list=[]
    for i in range(20):
        p=Process(target=f1,)
        p.start()
        p_list.append(p)
    [pp for pp in p_list]
    p_e_time=time.time()
    p_dif_time=p_e_time-p_s_time
    print('執行緒執行的時間%s'%t_dif_time)
    print('程序執行的時間%s' % p_dif_time)
###################
執行緒執行的時間0.003000497817993164
程序執行的時間0.2560145854949951

####鎖

import time
from multiprocessing import Process
from threading import Thread,Lock
num=100
def f1(loc):
    loc.acquire()
    global num
    tmp=num
    tmp-=1
    time.sleep(0.01)#模擬
    num=tmp
    loc.release()
if __name__ == '__main__':
    t_loc=Lock()
    t_list=[]
    for i in range(10):
        t=Thread(target=f1,args=(t_loc,))
        t.start()
        t_list.append(t)
    [tt.join() for tt in t_list]
    print('主程序',num)
##############
主程序 90

#####死鎖現象

import time
from threading import Thread,Lock,RLock
def f1(locA,locB):
    locA.acquire()
    print('f1>>1號搶到了A鎖')
    time.sleep(1)
    locB.acquire()
    print('f1>>1號搶到了B鎖')
    locB.release()
    locA.release()
def f2(locA,locB):
    locB.acquire()
    print('f2>>2號搶到了B鎖')
    locA.acquire()
    time.sleep(1)
    print('f2>>2號搶到了A鎖')
    locA.release()
    locB.release()
if __name__ == '__main__':
    locA = Lock()
    locB = Lock()
    t1 = Thread(target=f1,args=(locA,locB))
    t2 = Thread(target=f2,args=(locA,locB))
    t1.start()
    t2.start()
##################
f1>>1號搶到了A鎖
f2>>2號搶到了B鎖