day18 多线程 2018-08-08

多线程类似于同时执行多个不同程序,可以将耗时任务搁置到后台运行, 提高CPU利用率
python中多线程的使用方法:

python内置的threading模块,可以支持多线程
所有的进程默认都有一个线程(一般叫这个线程为主线程),其他的线程叫子线程
如果想要在进程中添加其他的线程,就创建线程对象

一、直接通过threading模块创建一个多线程对象

import threading
import time

def download(file, time1):
    print('开始下载',file)
    time.sleep(time1)
    print(file, '下载结束')

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

    # 1.创建线程对象
    """
    target: 需要在子线程中执行的函数
    args: 调用函数的实参列表(参数类型是列表)
    返回值: 线程对象
    """
    t1 = threading.Thread(target=download, args=['爱情公寓', 10])
    # 2.在子线程中执行任务
    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('!!!!')

二、写一个自己的线程类

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



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

    def run(self):
        """run方法"""
        """
        1.写在这个方法的内容就是在子线程中执行的内容
        2.这个方法不要直接调用
        """
        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间接调用run方法,run方法中的任务在子线程中执行
    t1.start()
    # 直接调用run方法,run方法中的任务在当前线程中执行
    # 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('!!!!!')

补充:

join()函数

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

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


class Download(Thread):
    def __init__(self, file):
        # 这儿父类的init方法必须调用,否则当前这个创建的对象中就没有新的线程
        super().__init__()
        self.file = file

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



if __name__ == '__main__':

    # time.time(): 获取当前时间-时间戳
    start_time = time.time()
    t1 = Download('最强Z.mp4')
    t1.start()

    t2 = Download('最强A.mp4')
    t2.start()

    print('====')
    # 获取当前线程
    """
    主线程: MainThread
    子线程: Thread-数字(数字从1开始。)
    """
    print(currentThread())

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

    # t2.join()
    end_time = time.time()
    print('总共消耗时间:%.2f' % (end_time - start_time))
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 一、Python简介和环境搭建以及pip的安装 4课时实验课主要内容 【Python简介】: Python 是一个...
    _小老虎_阅读 5,803评论 0 10
  • Python 面向对象Python从设计之初就已经是一门面向对象的语言,正因为如此,在Python中创建一个类和对...
    顺毛阅读 4,236评论 4 16
  • 进程与线程的区别 现在,多核CPU已经非常普及了,但是,即使过去的单核CPU,也可以执行多任务。由于CPU执行代码...
    苏糊阅读 781评论 0 2
  • 进程和线程 进程 所有运行中的任务通常对应一个进程,当一个程序进入内存运行时,即变成一个进程.进程是处于运行过程中...
    小徐andorid阅读 2,831评论 3 53
  • 时间:2016年1月21日 地点:户外 出发前的担忧 今天天气格外好,阳光普照大地,临近下课,Tyger心中突生一...
    Tyger老师阅读 748评论 14 19