一、python執行緒的模塊
1.thread和threading模塊
- thread模塊提供了基本的執行緒和鎖的支持
- threading提供了更高級別、功能更強的執行緒管理的功能，
2. Queue模塊
Queue模塊允許用戶創建一個可以用于多個執行緒之間共享資料的佇列資料結構，
3.注意模塊的選擇
- 避免使用thread模塊
- 因為更高級別的threading模塊更為先進，對執行緒的支持更為完善
- 而且使用thread模塊里的屬性有可能會與threading出現沖突；
- 其次低級別的thread模塊的同步原語很少(實際上只有一個)，而threading模塊則有很多；
- 再者，thread模塊中當主執行緒結束時，所有的執行緒都會被強制結束掉，沒有警告也不會有正常的清除作業，至少threading模塊能確保重要的子執行緒退出后行程才退出，
注意：thread模塊不支持守護執行緒，當主執行緒退出時，所有的子執行緒不論它們是否還在作業，都會被強行退出，而threading模塊支持守護執行緒，守護執行緒一般是一個等待客戶請求的服務器，如果沒有客戶提出請求它就在那等著，如果設定一個執行緒為守護執行緒，就表示這個執行緒是不重要的，在行程退出的時候，不用等待這個執行緒退出，
二、Threading模塊
multiprocess模塊的完全模仿了threading模塊的介面，二者在使用層面，有很大的相似性，因而不再詳細介紹
三、通過Threading.Thread類來創建執行緒
1 .創建執行緒的方式一
直接通過Threading.Thread來創建
from threading import Thread
import time
def task(name):
print(f'子執行緒{name} is running')
time.sleep(1)
print(f'子執行緒{name} is end')
# 因為創建執行緒不需要重新開辟記憶體空間，所以不用寫main，創建執行緒只是單獨把啟動執行緒函式里面的代碼拿出來用
t = Thread(target=task,args=('小明',))
t.start()
print('主執行緒結束')
2 創建執行緒的方式二
通過自定義類來繼承Thread類來創建執行緒
from threading import Thread
import time
class MyDic(Thread,name):
def __init__(self,name)
super().__init__()
self.name = name
def run(self):
print(f'子執行緒{name} is running')
time.sleep(1)
print(f'子執行緒{name} is end')
t = Mydic('小明')
t.start()
print('主行程結束')
四、多執行緒和多行程的比較
1 pid的比較
'''
學習中遇到問題沒人解答？小編創建了一個Python學習交流QQ群：711312441
尋找有志同道合的小伙伴，互幫互助,群里還有不錯的視頻學習教程和PDF電子書！
'''
from threading import Thread
from multiprocessing import Process
import time
import os
def task(name):
print(f'子執行緒{name} is running')
time.sleep(1)
print(f'子執行緒{name} is end')
print(f'子執行緒{name}的pid：{os.getpid()}')
def task1(name):
print(f'行程{name} is running')
time.sleep(1)
print(f'行程{name} is end')
print(f'行程的{name}pid：{os.getpid()}')
if __name__ == '__main__':
# part1:在主行程下開啟多個執行緒,每個執行緒都跟主行程的pid一樣
t = Thread(target=task, args=('小明',))
t.start()
t.join()
print(f'主執行緒的pid：{os.getpid()}')
# 開多個行程，每一個行程的pid號都不一樣
p = Process(target=task1,args=('zhangsan',))
p1 = Process(target=task1,args=('zhang',))
p.start()
p1.start()
p.join()
p1.join()
print(f'主行程的pid：{os.getpid()}')
2 執行緒和行程開啟效率的較量
from threading import Thread
from multiprocessing import Process
import time
def task(name):
print(f'{name} is running')
time.sleep(2)
print(f'{name} is end')
if __name__ == '__main__':
t = Thread(target=task,args=('子執行緒',))
p = Process(target=task,args=('子行程',))
t.start()
# p.start()
print('主')
（1.開啟執行緒的速度:
子執行緒 is running
主
子執行緒 is end
（2.開啟行程的速度：
主
子行程 is running
子行程 is end
3 記憶體資料共享問題
from threading import Thread
from multiprocessing import Process
import time,os
x = 100
def task():
global x
x = 50 # 此時執行緒是在拿全域的x的值
print(os.getpid()) # 因為開啟執行緒是不需要作業系統給執行緒分配記憶體空間的，所以執行緒用的是它當前所在的行程的行程號
if __name__ == '__main__':
# 執行緒
t = Thread(target=task)
t.start()
time.sleep(2)
print(x) # 50，這里說明執行緒他是共享他所在行程下的所有資源，對資源進行一系列的操作
print(os.getpid())
# 行程
# p = Process(target=task)
# p.start()
# print(x) # 這里的x還是主行程的x 100
五、Thread類的其他方法
Thread實體物件的方法：
- isAlive()：回傳執行緒是否活動的，
- getName()：回傳執行緒名，
- setName()：設定執行緒名，
threading模塊提供的一些方法：
- threading.currentThread()：回傳當前的執行緒變數，
- threading.enumerate()：回傳一個包含正在運行的執行緒的list，正在運行指執行緒啟動后、結束前，不包括啟動前和終止后的執行緒，
- threading.activeCount()：回傳正在運行的執行緒數量，與len(threading.enumerate())有相同的結果，
1 代碼實體
from threading import Thread,currentThread,enumerate,activeCount
import time
def task():
print('子執行緒 start')
time.sleep(2)
print('子執行緒 end')
print(enumerate())# 回傳一個包含正在運行的執行緒的list，正在運行指執行緒啟動后、結束前，不包括啟動前和終止后的執行緒，
print(currentThread(),'子執行緒') # 回傳當前的執行緒變數
print(activeCount())
if __name__ == '__main__':
t1 = Thread(target=task)
t2 = Thread(target=task)
t1.start()
t2.start()
t2.setName('小明')
print(t2.getName()) # 得到t2的執行緒名字，是我們設定好的小明
print(t1.getName()) # 得到t1的執行緒名子 Thread-1
print(t1.is_alive()) # True
2 join方法
'''
學習中遇到問題沒人解答？小編創建了一個Python學習交流QQ群：711312441
尋找有志同道合的小伙伴，互幫互助,群里還有不錯的視頻學習教程和PDF電子書！
'''
from threading import Thread
import time
def task():
print('子執行緒 start')
time.sleep(2)
print('子執行緒 end')
t = Thread(target=task)
t.start()
t.join() # 等待子執行緒運行結束
print('主執行緒')
六、多執行緒實作socket
1 服務端
import socket
from threading import Thread
socket = socket.socket(socket.AF_INET,socket.SOCK_STREAM)
socket.bind(('192.168.11.78',8004))
socket.listen(5)
def action(conn,addr):
while True:
try:
msg = (conn.recv(1024)).decode('utf8').upper()
print(f'客戶端{addr}發送的資料為：{msg.lower()}')
print(f'向客戶端{addr}發送資料為',msg)
conn.send(msg.encode('utf8'))
except:
break
if __name__ == '__main__':
print('等待客戶端連接:')
while True:
try:
conn,addr = socket.accept()
print(f'客戶端已連接{addr}')
t = Thread(target=action,args=(conn,addr))
t.start()
except:
print(f'客戶端{addr}斷開連接 ！！')
break
2 客戶端
import socket
client = socket.socket()
client.connect(('192.168.11.78',8004))
while True:
msg = input('輸入：')
if msg == 'q':
break
client.send(msg.encode('utf8'))
flag = client.recv(1024)
print('接收服務端的資料為：',flag.decode('utf8'))
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/540971.html
標籤：Python
上一篇：乾坤大挪移,如何將同步阻塞(sync)三方庫包轉換為異步非阻塞(async)模式？Python3.10實作。
下一篇：學習匯編-32位