提到python的多執行緒,大家都說雞肋。至於為什麼,一定又要說什麼「gil的全稱是global interpreter lock(全域性直譯器鎖)」之類的解釋了,哥書讀的少,聽不太懂,反正能讓我們這種村裡人看到同時跑了幾個就行,至於什麼多執行緒多程序,cpu是並行還是併發的,都隨他去吧。
今天主要說一下threading模組的程序鎖與程序管理內容。
用threading有幾次,都是簡單的有兩個或者三個任務需要併發執行,比如伺服器的主備等等,不用管它鎖不鎖的。但這次想用於管理幾百個任務的依次併發,不得不看看了。
先說下threading.lock()
由於存在多個程序共同去修改某個資料的問題,所以必須要用到lock()
這東西比較簡單,lock.acquire()用於新增鎖,lock.release() 用於釋放鎖。太簡單就不舉例子了。
重點說下threading.semaphore
semaphore 在內部存在乙個計數器,在使用者呼叫 acquire() 時,計數器 -1,release() 則+1
舉個例子說明下吧,剛好用下下午的簡單測試**:
複製**
1 from selenium import webdriver
2 import threading
3 import time
4 import random56
7 def first_test(url):
8 sem.acquire() # 注意要第一時間去修改計數器 這點很重要
9 firsttest = webdriver.chrome()
10 try:
11 firsttest.get(url) # 傳送get請求
12 time.sleep(random.randint(0, 50)) # 為了看清變化 random設定的比較大
13 except exception as errorinfo:
14 print(errorinfo)
15 finally:
16 sem.release()
17 firsttest.close() # 關閉谷歌瀏覽器
1819
20 ifname== 『main』:
21 url = 『
22 sem = threading.semaphore(3) # 設定執行緒閥值
23 for i in range(10):
24 t = threading.thread(target=first_test, args=(url,))
25 t.start()
26 time.sleep(0.1)
2728 while threading.active_count() != 1:
29 pass # print threading.active_count()
30 else:
31 print(』### selenium jobs is over!!!###』)
複製**
由於為了保證計數器的不為負(因為變成負數,就相當於阻塞了哦…),最好使用finally,來進行release()的修改…
好了,點滴積累…
Python3多執行緒
學習python執行緒 python3 執行緒中常用的兩個模組為 thread threading 推薦使用 thread 模組已被廢棄。使用者可以使用 threading 模組代替。所以,在 python3 中不能再使用 thread 模組。為了相容性,python3 將 thread 重新命名為...
python3 多執行緒
多執行緒簡介 執行緒 thread 也稱輕量級程序,時作業系統能夠進行運算排程的最小單位,它被包涵在程序之中,時程序中的實際運作單位。執行緒自身不擁有資源,只擁有一些在執行中必不可少的資源,但他可與同屬乙個程序的其他執行緒共享程序所擁有的全部資源。乙個執行緒可以建立和撤銷另乙個執行緒,同一程序中的多...
python3 多執行緒,執行緒鎖
python使用多執行緒,不一定執行速度快,這裡引入gil global interpreter lock python直譯器中任意時刻都只有乙個執行緒在執行 gil執行過程 1 設定乙個gil 2 切換執行緒去準備執行任務 runnale就緒狀態 3 執行 4 可能出現的狀態 執行緒任務執行結束 ...