day18 多線程 2018-08-08

多線程類似于同時(shí)執(zhí)行多個(gè)不同程序,可以將耗時(shí)任務(wù)擱置到后臺(tái)運(yùn)行, 提高CPU利用率
python中多線程的使用方法:

python內(nèi)置的threading模塊,可以支持多線程
所有的進(jìn)程默認(rèn)都有一個(gè)線程(一般叫這個(gè)線程為主線程),其他的線程叫子線程
如果想要在進(jìn)程中添加其他的線程,就創(chuàng)建線程對(duì)象

一、直接通過threading模塊創(chuàng)建一個(gè)多線程對(duì)象

import threading
import time

def download(file, time1):
    print('開始下載',file)
    time.sleep(time1)
    print(file, '下載結(jié)束')

if __name__ == '__main__':
    print('abc')

    # 1.創(chuàng)建線程對(duì)象
    """
    target: 需要在子線程中執(zhí)行的函數(shù)
    args: 調(diào)用函數(shù)的實(shí)參列表(參數(shù)類型是列表)
    返回值: 線程對(duì)象
    """
    t1 = threading.Thread(target=download, args=['愛情公寓', 10])
    # 2.在子線程中執(zhí)行任務(wù)
    t1.start()

    t2 = threading.Thread(target=download, args=['狄仁杰', 5])
    t2.start()

    # download('愛情公寓')
    # download('狄仁杰')
    print('=====')

    # t3 = threading.Thread(target=input, args=['>>>'])
    # t3.start()
    value = input('>>>')
    print('!!!!')

二、寫一個(gè)自己的線程類

  1. 寫一個(gè)類,繼承自Thread類
  2. 重寫run方法,在里面規(guī)定需要在子線程中執(zhí)行的任務(wù)
  3. 實(shí)現(xiàn)在子線程中執(zhí)行的任務(wù)對(duì)應(yīng)的功能,如果需要參數(shù),通過類的對(duì)象屬性來傳值
from threading import Thread
import requests
import re



# 下載數(shù)據(jù)
class DownloadThread(Thread):
    """下載類"""
    def __init__(self, file_path):
        super().__init__()
        self.file_path = file_path

    def run(self):
        """run方法"""
        """
        1.寫在這個(gè)方法的內(nèi)容就是在子線程中執(zhí)行的內(nèi)容
        2.這個(gè)方法不要直接調(diào)用
        """
        print('開始下載')
        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')
    # 通過start間接調(diào)用run方法,run方法中的任務(wù)在子線程中執(zhí)行
    t1.start()
    # 直接調(diào)用run方法,run方法中的任務(wù)在當(dāng)前線程中執(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è)子線程中的任務(wù)執(zhí)行完成后再執(zhí)行,就在當(dāng)前任務(wù)前用子線程對(duì)象調(diào)用join方法
所以join也會(huì)阻塞線程,阻塞到對(duì)應(yīng)的子線程中任務(wù)執(zhí)行完為止

from threading import Thread,currentThread
import time
from random import randint


class Download(Thread):
    def __init__(self, file):
        # 這兒父類的init方法必須調(diào)用,否則當(dāng)前這個(gè)創(chuàng)建的對(duì)象中就沒有新的線程
        super().__init__()
        self.file = file

    def run(self):
        print(currentThread())
        print('開始下載:%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)前線程
    """
    主線程: MainThread
    子線程: Thread-數(shù)字(數(shù)字從1開始。)
    """
    print(currentThread())

    # 如果一個(gè)任務(wù)想要在另外一個(gè)子線程中的任務(wù)執(zhí)行完成后再執(zhí)行,就在當(dāng)前任務(wù)前用子線程對(duì)象調(diào)用join方法
    # 所以join也會(huì)阻塞線程,阻塞到對(duì)應(yīng)的子線程中任務(wù)執(zhí)行完為止
    t1.join()

    # t2.join()
    end_time = time.time()
    print('總共消耗時(shí)間:%.2f' % (end_time - start_time))
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
【社區(qū)內(nèi)容提示】社區(qū)部分內(nèi)容疑似由AI輔助生成,瀏覽時(shí)請(qǐng)結(jié)合常識(shí)與多方信息審慎甄別。
平臺(tái)聲明:文章內(nèi)容(如有圖片或視頻亦包括在內(nèi))由作者上傳并發(fā)布,文章內(nèi)容僅代表作者本人觀點(diǎn),簡(jiǎn)書系信息發(fā)布平臺(tái),僅提供信息存儲(chǔ)服務(wù)。

相關(guān)閱讀更多精彩內(nèi)容

友情鏈接更多精彩內(nèi)容