多線(xiàn)程類(lèi)似于同時(shí)執(zhí)行多個(gè)不同程序塔粒,可以將耗時(shí)任務(wù)擱置到后臺(tái)運(yùn)行, 提高CPU利用率
python中多線(xiàn)程的使用方法:
python內(nèi)置的threading模塊弦叶,可以支持多線(xiàn)程
所有的進(jìn)程默認(rèn)都有一個(gè)線(xiàn)程(一般叫這個(gè)線(xiàn)程為主線(xiàn)程)例获,其他的線(xiàn)程叫子線(xiàn)程
如果想要在進(jìn)程中添加其他的線(xiàn)程匾鸥,就創(chuàng)建線(xiàn)程對(duì)象
一京腥、直接通過(guò)threading模塊創(chuàng)建一個(gè)多線(xiàn)程對(duì)象
import threading
import time
def download(file, time1):
print('開(kāi)始下載',file)
time.sleep(time1)
print(file, '下載結(jié)束')
if __name__ == '__main__':
print('abc')
# 1.創(chuàng)建線(xiàn)程對(duì)象
"""
target: 需要在子線(xiàn)程中執(zhí)行的函數(shù)
args: 調(diào)用函數(shù)的實(shí)參列表(參數(shù)類(lèi)型是列表)
返回值: 線(xiàn)程對(duì)象
"""
t1 = threading.Thread(target=download, args=['愛(ài)情公寓', 10])
# 2.在子線(xiàn)程中執(zhí)行任務(wù)
t1.start()
t2 = threading.Thread(target=download, args=['狄仁杰', 5])
t2.start()
# download('愛(ài)情公寓')
# download('狄仁杰')
print('=====')
# t3 = threading.Thread(target=input, args=['>>>'])
# t3.start()
value = input('>>>')
print('!!!!')
二鲸郊、寫(xiě)一個(gè)自己的線(xiàn)程類(lèi)
- 寫(xiě)一個(gè)類(lèi)丰榴,繼承自Thread類(lèi)
- 重寫(xiě)run方法,在里面規(guī)定需要在子線(xiàn)程中執(zhí)行的任務(wù)
- 實(shí)現(xiàn)在子線(xiàn)程中執(zhí)行的任務(wù)對(duì)應(yīng)的功能秆撮,如果需要參數(shù)四濒,通過(guò)類(lèi)的對(duì)象屬性來(lái)傳值
from threading import Thread
import requests
import re
# 下載數(shù)據(jù)
class DownloadThread(Thread):
"""下載類(lèi)"""
def __init__(self, file_path):
super().__init__()
self.file_path = file_path
def run(self):
"""run方法"""
"""
1.寫(xiě)在這個(gè)方法的內(nèi)容就是在子線(xiàn)程中執(zhí)行的內(nèi)容
2.這個(gè)方法不要直接調(diào)用
"""
print('開(kāi)始下載')
response = requests.request('GET', self.file_path)
data = response.content
# 獲取文件后綴
suffix = re.search(r'\.\w+$', self.file_path).group()
with open('./abc'+suffix, 'wb') as f:
f.write(data)
print('下載完成...')
if __name__ == '__main__':
print('=====')
t1 = DownloadThread('http://10.7.181.117/shareX/Git.exe')
# 通過(guò)start間接調(diào)用run方法,run方法中的任務(wù)在子線(xiàn)程中執(zhí)行
t1.start()
# 直接調(diào)用run方法,run方法中的任務(wù)在當(dāng)前線(xiàn)程中執(zhí)行
# t1.run()
t2 = DownloadThread('https://timgsa.baidu.com/timg?image&quality=80&size=b9999_10000&sec=1533720058151&di=766b5c97653351e805c85881ecaa57d0&imgtype=0&src=http%3A%2F%2Fx.itunes123.com%2Fuploadfiles%2Fb2ab55461e6dc7a82895c7425fc89017.jpg')
t2.start()
print('!!!!!')
補(bǔ)充:
join()函數(shù)
如果一個(gè)任務(wù)想要在另外一個(gè)子線(xiàn)程中的任務(wù)執(zhí)行完成后再執(zhí)行峻黍,就在當(dāng)前任務(wù)前用子線(xiàn)程對(duì)象調(diào)用join方法
所以join也會(huì)阻塞線(xiàn)程复隆,阻塞到對(duì)應(yīng)的子線(xiàn)程中任務(wù)執(zhí)行完為止
from threading import Thread,currentThread
import time
from random import randint
class Download(Thread):
def __init__(self, file):
# 這兒父類(lèi)的init方法必須調(diào)用,否則當(dāng)前這個(gè)創(chuàng)建的對(duì)象中就沒(méi)有新的線(xiàn)程
super().__init__()
self.file = file
def run(self):
print(currentThread())
print('開(kāi)始下載:%s' % self.file)
time.sleep(randint(5, 10))
print('%s下載結(jié)束' % self.file)
if __name__ == '__main__':
# time.time(): 獲取當(dāng)前時(shí)間-時(shí)間戳
start_time = time.time()
t1 = Download('最強(qiáng)Z.mp4')
t1.start()
t2 = Download('最強(qiáng)A.mp4')
t2.start()
print('====')
# 獲取當(dāng)前線(xiàn)程
"""
主線(xiàn)程: MainThread
子線(xiàn)程: Thread-數(shù)字(數(shù)字從1開(kāi)始姆涩。)
"""
print(currentThread())
# 如果一個(gè)任務(wù)想要在另外一個(gè)子線(xiàn)程中的任務(wù)執(zhí)行完成后再執(zhí)行挽拂,就在當(dāng)前任務(wù)前用子線(xiàn)程對(duì)象調(diào)用join方法
# 所以join也會(huì)阻塞線(xiàn)程,阻塞到對(duì)應(yīng)的子線(xiàn)程中任務(wù)執(zhí)行完為止
t1.join()
# t2.join()
end_time = time.time()
print('總共消耗時(shí)間:%.2f' % (end_time - start_time))