Python中如何創(chuàng)建多線程？
更新時(shí)間：2023年01月06日 08:37:25 作者：python學(xué)習(xí)者0
這篇文章主要介紹了Python中如何創(chuàng)建多線程的相關(guān)資料,需要的朋友可以參考下
一、python線程的模塊
1.thread和threading模塊
- thread模塊提供了基本的線程和鎖的支持
- threading提供了更高級(jí)別、功能更強(qiáng)的線程管理的功能。
2. Queue模塊
Queue模塊允許用戶創(chuàng)建一個(gè)可以用于多個(gè)線程之間共享數(shù)據(jù)的隊(duì)列數(shù)據(jù)結(jié)構(gòu)。
3.注意模塊的選擇
- 避免使用thread模塊
- 因?yàn)楦呒?jí)別的threading模塊更為先進(jìn)，對(duì)線程的支持更為完善
- 而且使用thread模塊里的屬性有可能會(huì)與threading出現(xiàn)沖突；
- 其次低級(jí)別的thread模塊的同步原語很少(實(shí)際上只有一個(gè))，而threading模塊則有很多；
- 再者，thread模塊中當(dāng)主線程結(jié)束時(shí)，所有的線程都會(huì)被強(qiáng)制結(jié)束掉，沒有警告也不會(huì)有正常的清除工作，至少threading模塊能確保重要的子線程退出后進(jìn)程才退出。
注意：thread模塊不支持守護(hù)線程，當(dāng)主線程退出時(shí)，所有的子線程不論它們是否還在工作，都會(huì)被強(qiáng)行退出。而threading模塊支持守護(hù)線程，守護(hù)線程一般是一個(gè)等待客戶請(qǐng)求的服務(wù)器，如果沒有客戶提出請(qǐng)求它就在那等著，如果設(shè)定一個(gè)線程為守護(hù)線程，就表示這個(gè)線程是不重要的，在進(jìn)程退出的時(shí)候，不用等待這個(gè)線程退出。
二、Threading模塊
multiprocess模塊的完全模仿了threading模塊的接口，二者在使用層面，有很大的相似性，因而不再詳細(xì)介紹
三、通過Threading.Thread類來創(chuàng)建線程
1 .創(chuàng)建線程的方式一
直接通過Threading.Thread來創(chuàng)建
from threading import Thread
import time
def task(name):
print(f'子線程{name} is running')
time.sleep(1)
print(f'子線程{name} is end')
# 因?yàn)閯?chuàng)建線程不需要重新開辟內(nèi)存空間，所以不用寫main，創(chuàng)建線程只是單獨(dú)把啟動(dòng)線程函數(shù)里面的代碼拿出來用
t = Thread(target=task,args=('小明',))
t.start()
print('主線程結(jié)束')
2 創(chuàng)建線程的方式二
通過自定義類來繼承Thread類來創(chuàng)建線程
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('主進(jìn)程結(jié)束')
四、多線程和多進(jìn)程的比較
1 pid的比較
'''
學(xué)習(xí)中遇到問題沒人解答？小編創(chuàng)建了一個(gè)Python學(xué)習(xí)交流QQ群：711312441
尋找有志同道合的小伙伴，互幫互助,群里還有不錯(cuò)的視頻學(xué)習(xí)教程和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'進(jìn)程{name} is running')
time.sleep(1)
print(f'進(jìn)程{name} is end')
print(f'進(jìn)程的{name}pid：{os.getpid()}')
if __name__ == '__main__':
# part1:在主進(jìn)程下開啟多個(gè)線程,每個(gè)線程都跟主進(jìn)程的pid一樣
t = Thread(target=task, args=('小明',))
t.start()
t.join()
print(f'主線程的pid：{os.getpid()}')
# 開多個(gè)進(jìn)程，每一個(gè)進(jìn)程的pid號(hào)都不一樣
p = Process(target=task1,args=('zhangsan',))
p1 = Process(target=task1,args=('zhang',))
p.start()
p1.start()
p.join()
p1.join()
print(f'主進(jìn)程的pid：{os.getpid()}')
2 線程和進(jìn)程開啟效率的較量
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=('子進(jìn)程',))
t.start()
# p.start()
print('主')
（1.開啟線程的速度:
子線程 is running 主 子線程 is end
（2.開啟進(jìn)程的速度：
主 子進(jìn)程 is running 子進(jìn)程 is end
3 內(nèi)存數(shù)據(jù)共享問題
from threading import Thread
from multiprocessing import Process
import time,os
x = 100
def task():
global x
x = 50 # 此時(shí)線程是在拿全局的x的值
print(os.getpid()) # 因?yàn)殚_啟線程是不需要操作系統(tǒng)給線程分配內(nèi)存空間的，所以線程用的是它當(dāng)前所在的進(jìn)程的進(jìn)程號(hào)
if __name__ == '__main__':
# 線程
t = Thread(target=task)
t.start()
time.sleep(2)
print(x) # 50，這里說明線程他是共享他所在進(jìn)程下的所有資源，對(duì)資源進(jìn)行一系列的操作
print(os.getpid())
# 進(jìn)程
# p = Process(target=task)
# p.start()
# print(x) # 這里的x還是主進(jìn)程的x 100
五、Thread類的其他方法
Thread實(shí)例對(duì)象的方法：
- isAlive()：返回線程是否活動(dòng)的。
- getName()：返回線程名。
- setName()：設(shè)置線程名。
threading模塊提供的一些方法：
- threading.currentThread()：返回當(dāng)前的線程變量。
- threading.enumerate()：返回一個(gè)包含正在運(yùn)行的線程的list。正在運(yùn)行指線程啟動(dòng)后、結(jié)束前，不包括啟動(dòng)前和終止后的線程。
- threading.activeCount()：返回正在運(yùn)行的線程數(shù)量，與len(threading.enumerate())有相同的結(jié)果。
1 代碼實(shí)例
from threading import Thread,currentThread,enumerate,activeCount
import time
def task():
print('子線程 start')
time.sleep(2)
print('子線程 end')
print(enumerate())# 返回一個(gè)包含正在運(yùn)行的線程的list。正在運(yùn)行指線程啟動(dòng)后、結(jié)束前，不包括啟動(dòng)前和終止后的線程。
print(currentThread(),'子線程') # 返回當(dāng)前的線程變量
print(activeCount())
if __name__ == '__main__':
t1 = Thread(target=task)
t2 = Thread(target=task)
t1.start()
t2.start()
t2.setName('小明')
print(t2.getName()) # 得到t2的線程名字，是我們?cè)O(shè)置好的小明
print(t1.getName()) # 得到t1的線程名子 Thread-1
print(t1.is_alive()) # True
2 join方法
'''
學(xué)習(xí)中遇到問題沒人解答？小編創(chuàng)建了一個(gè)Python學(xué)習(xí)交流QQ群：711312441
尋找有志同道合的小伙伴，互幫互助,群里還有不錯(cuò)的視頻學(xué)習(xí)教程和PDF電子書！
'''
from threading import Thread
import time
def task():
print('子線程 start')
time.sleep(2)
print('子線程 end')
t = Thread(target=task)
t.start()
t.join() # 等待子線程運(yùn)行結(jié)束
print('主線程')
六、多線程實(shí)現(xiàn)socket
1 服務(wù)端
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'客戶端{(lán)addr}發(fā)送的數(shù)據(jù)為：{msg.lower()}')
print(f'向客戶端{(lán)addr}發(fā)送數(shù)據(jù)為',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'客戶端{(lán)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('接收服務(wù)端的數(shù)據(jù)為：',flag.decode('utf8'))到此這篇關(guān)于Python中如何創(chuàng)建多線程？的文章就介紹到這了,更多相關(guān)Python創(chuàng)建多線程內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Windows中安裝使用Virtualenv來創(chuàng)建獨(dú)立Python環(huán)境
有時(shí)我們的程序中需要調(diào)用不同版本的Python包和模塊,那么借助Virtualenv的虛擬環(huán)境就可以幫助我們隔離使用,接下來我們就來看一下在Windows中安裝使用Virtualenv來創(chuàng)建獨(dú)立Python環(huán)境的方法2016-05-05
這篇文章主要介紹了python通配符之glob模塊的使用詳解，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2021-04-04
Python實(shí)現(xiàn)string字符串連接的方法總結(jié)【8種方式】
這篇文章主要介紹了Python實(shí)現(xiàn)string字符串連接的方法,結(jié)合實(shí)例形式總結(jié)分析了Python實(shí)現(xiàn)字符串連接的8種常見操作技巧,需要的朋友可以參考下2018-07-07
Numpy中np.vstack()?和?np.hstack()?的實(shí)現(xiàn)
本文主要介紹了Numpy中np.vstack()和np.hstack()的實(shí)現(xiàn),文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2024-04-04
Python?functools凍結(jié)參數(shù)小技巧實(shí)現(xiàn)代碼簡(jiǎn)潔優(yōu)化
這篇文章主要為大家介紹了Python?functools凍結(jié)參數(shù)小技巧實(shí)現(xiàn)代碼簡(jiǎn)潔優(yōu)化示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-12-12
這篇文章主要介紹了Pytorch如何快速計(jì)算余弦相似性矩陣問題,具有很好的參考價(jià)值,希望對(duì)大家有所幫助,如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2024-02-02
Python telnet登陸功能實(shí)現(xiàn)代碼
這篇文章主要介紹了Python telnet登陸功能實(shí)現(xiàn)代碼,文中通過示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-04-04
這篇文章主要介紹了python開發(fā)之list操作方法,結(jié)合實(shí)例形式分析了list操作的具體用法與相關(guān)注意事項(xiàng),需要的朋友可以參考下2016-02-02
Python代碼中引用已經(jīng)寫好的模塊、方法的兩種方式
這篇文章主要介紹了Python代碼中引用已經(jīng)寫好的模塊、方法,下面就介紹兩種方式，可以簡(jiǎn)潔明了地調(diào)用自己在其他模塊寫的代碼，需要的朋友可以參考下2022-07-07
這篇文章主要介紹了python復(fù)制與引用,實(shí)例分析了python中復(fù)制與引用的具體使用技巧,具有一定參考借鑒價(jià)值,需要的朋友可以參考下2015-04-04