美文网首页
day18 多线程 2018-08-08

day18 多线程 2018-08-08

作者: LPP27149 | 来源:发表于2018-08-08 20:05 被阅读0次

    多线程类似于同时执行多个不同程序,可以将耗时任务搁置到后台运行, 提高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))
    

    相关文章

      网友评论

          本文标题:day18 多线程 2018-08-08

          本文链接:https://www.haomeiwen.com/subject/fkzxbftx.html