18 多线程

1.引入线程

所有的进程默认都有一个线程(一般这个线程为主线程), 有时需要在程序执行的过程中要做多件事情,但是又不会影响主程序的运行.(比如:在播放器听歌的时候,下载别的歌曲),这时候就要添加线程.
如果想要在进程中添加其他的线程,就创建线程对象
python内置的threading模块,可以支持多线程

2.使用多线程

方法1:使用thread.Thread()方法,传递参数创建线程对象

 t1 = threading.Thread(target=download, args=['爱情公寓'])
"""
    target:需要在子线程中执行的函数
    args:调用函数的实参列表(参数类型是列表)
    返回值:先成对象
"""

实现方式:

import threading
import time

def download(file):
    print('开始下载', file)
    time.sleep(5)
    print(file, '下载成功')

if __name__ == '__main__':
    print('abc')
    # 1.创建线程对象
    t1 = threading.Thread(target=download, args=['爱情公寓'])

    # 2.在子线程中执行任务
    t1.start()

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

    print('======')

#输出
F:\Pythonworkspace\day18\多线程\venv\Scripts\python.exe F:/Pythonworkspace/day18/多线程/01-多线程技术.py
abc
开始下载 爱情公寓
开始下载 狄仁杰
======
狄仁杰 下载成功
爱情公寓 下载成功

此方法是自己创建一个函数,然后创建一个线程对象去掉用这个函数,实现了函数在线程里执行,不影响主线程的执行.

方法2:写一个自己的线程类
- 1.写一个类,继承自Thread类
- 2.重写run方法,在里面规定需要在子线程中执行的任务
- 3.在子线程中执行的任务对应的功能,如果需要参数,通过对象属性来传值.

import requests
from threading import Thread
import re


# 下载数据
class DownloadThread(Thread):
    """下载类"""
    def __init__(self, file_path):
        super().__init__()
        self.file_path = file_path

    def run(self):

        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('https://www.duba.com/static/images/public/20180808/news/6609c93d70cf3bc799695627dd00baa1cc112a8b.jpg')
    t1.start()
    print('!!!!')

#运行
=====
开始下载
!!!!
下载完成

注意:此处不能用t1.run()的方式执行run方法里面的内容,否则会按照常规的对象方法的方式执行,会影响主线程的运行.

从链接获取的图片

3.join, current_thread 和 time.time

(1)join()

如果一个任务想要在另外一个子线程中的任务执行完成后再执行,就在当前任务前用子线程对象调用join方法 所以join也会阻塞线程,阻塞到对应的子线程中的任务执行完为止

t1.start()
t1.join()

(2)current_thread()

此方法用来判断当前执行内容在哪一个线程里面(这个方法在threading这个库里)

如果是主线程,则返回的内容包括:MainThread
如果是子线程,则返回:Thread-数字(数字从1开始)

(3)time.time()

在python有time这样一个库(内置),用于获取当前的时间戳,用两个不同的时间戳求差,可算出程序执行花费了多少时间.

import time
start_time = time.time()
end_time = time.time()
all_time = start_time - end_time

实例:

"""__author__ = Sun Jiankang"""

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

class Download(Thread):
    def __init__(self, file):
        super().__init__()
        self.file = file

    def run(self):
        """模拟下载"""
        print('开始下载%s' % self.file)
        print(current_thread())
        time.sleep(randint(5, 10))
        print('%s 下载结束' % self.file)

if __name__ == '__main__':

    start_time = time.time()
    t2 = Download('最强.mp4')
    t2.start()
    print('-----------')

    print(current_thread())
    t1 = Download('最强z.mp4')
    t1.start()
    t1.join()
    end_time = time.time()
    print('总共消耗时间:%.2f' % (end_time - start_time))


# 输出
开始下载最强.mp4
<Download(Thread-1, started 56716)>
-----------
<_MainThread(MainThread, started 104812)>
开始下载最强z.mp4
<Download(Thread-2, started 58652)>
最强z.mp4 下载结束
总共消耗时间:7.00
最强.mp4 下载结束