美文网首页
day18 多线程

day18 多线程

作者: 跟我念一遍 | 来源:发表于2018-08-08 20:42 被阅读0次

    01多线程技术1

    python 内置的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('狄仁杰')
        time.sleep(3)
    
        print('======')
    
        # value = input('>>>')
        # print('!!!!')
    

    02多线程技术2

    方式2:写一个自己的线程类

    • 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()
        # 通过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('!!!!!!!')
    

    03多线程应用

    import socket
    from threading import Thread
    
    class ConversationThread(Thread):
        """在子线程中处理不同的客户端"""
        """
        python中可以在函数参数的后面加一个冒号,来对参数的类型进行说明
        """
        def __init__(self, conversation:socket.socket, address):
            super.__init__()
            self.conversation = conversation
            self.address = address
    
        def run(self):
            while True:
                self.conversation.send('你好!'.encode())
                print(self.conversation.recv(1024).decode(encoding='utf-8'))
    
    
    
    if __name__ == '__main__':
        server = socket.socket()
        server.bind(('10.7.181.117', 8080))
        server.listen(10)
    
        while True:
            conversation, addr = server.accept()
    
            t = ConversationThread(conversation, addr)
            t.start()
    

    04 join

    from threading import Thread, currentThread
    from random import randint
    import time
    
    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('最强,mp4')
        t2.start()
        print('==========')
        # 获取当前线程
        """
        主线程:MainThread
        子线程:Thread - 数字(数字从1开始)
        """
        # 如果一个任务想要在另外一个子线程的任务执行完成后在执行,就在当前任务前用子线程对象调用join方法
        # 所以join也会阻塞线程,租的到对应的子线程中任务执行完为止
        t1.join()
        t2.join()
        print('==========')
        end_time = time.time()
        print('总共消耗时间:%.2f' % (end_time - start_time))
    

    05 耗时操作

    def rand_color():
        return randint(0, 255),randint(0, 255),randint(0, 255)
    
    def long_time():
        print('耗时操作开始')
        time.sleep(10)
        print('耗时操作结束')
    
    def download(file):
        print('开始下载',file)
        time.sleep(10)
        print(file, '下载结束')
    
    if __name__ == '__main__':
        print('====')
        print(time.time())
        download('狄仁杰')
        download('爱情公寓')
        print(time.time())
        print('!!!')
    

    相关文章

      网友评论

          本文标题:day18 多线程

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