Day18 多线程

01.多线程技术1

02.多线程技术2

03.多线程应用

04.join 函数


耗时操作

  • 1.耗时操作放到主线程中的问题:
    耗时操作放到主线进程中,会阻塞线程
    多个耗时操作都放到一个线程中执行,最终执行的时间是两个耗时操作的时间和

  • 2.怎么解决问题?
    使用多线程(创建多个线程)

01.多线程技术1

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

import threading
import time

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

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

    # 1.创建线程对象
    '''
    target:需要在子线程中执行的函数
    args:调用函数的实参列表
    返回值:线程对象
    '''

    t1 = threading.Thread(target=download,args=['爱情公寓'])

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

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

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

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

02.多线程技术2

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

import re
from threading import Thread
import requests

# 下载数据
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('./git'+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('http://10.7.181.117/shareX/Git.exe')
    print('!!!')

run方法

  • 1.写在这个方法的内容就是在子线程中执行的内容
  • 2.这个方法不要直接调用,直接调用run方法,run方法中的任务在当前线程中执行

03.多线程应用

通过子线程处理同时与多个客户端的会话

import socket
from threading import Theard

class Conversation(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.address,self.conversation.recv(1024)decode(encoding='utf-8'))

if __name__ == '__main__':
    server = socket.socket()
    server.bind(('10.7.181.118',1025))
    server.listen(50)

    while True:
        conversation,address = server.accept()

        t = ConversationThread(conversation,address)
        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('开始下载:%s' % self.file)
        time.sleep(randint(5,10))
        print('%s下载结束' % self.file)
        print(currentThread())


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

    t2 = Download('最强A.mp4')
    t2.start()
    # 获取当前线程
    '''
    主线程:MainThread()
    子线程:Thread-数字(数字从1开始)'''
    print(currentThread())

    # 如果一个任务想要在另外一个子线程中的任务执行完成后再执行,就在当前任务前用子线程对象调用join方法
    # 所以join也会阻塞线程,阻塞到对应的子线程中任务执行完为止
    t1.join()
    # t2.join()
    end_time = time.time()
    print('总共消耗时间:%.2f' % (end_time-start_time))
  • 获取当前线程:currentThread
  • 如果一个任务想要在另外一个子线程中的任务执行完成后再执行,就在当前任务前用子线程对象调用join方法。所以join也会阻塞线程,阻塞到对应的子线程中任务执行完为止
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 第5章 多线程编程 5.1 线程基础 5.1.1 如何创建线程 在java要创建线程,一般有==两种方式==:1)...
    AndroidMaster阅读 1,810评论 0 11
  •   一个任务通常就是一个程序,每个运行中的程序就是一个进程。当一个程序运行时,内部可能包含了多个顺序执行流,每个顺...
    OmaiMoon阅读 1,706评论 0 12
  • 进程和线程 进程 所有运行中的任务通常对应一个进程,当一个程序进入内存运行时,即变成一个进程.进程是处于运行过程中...
    小徐andorid阅读 2,844评论 3 53
  • 1.配置Tomcat 1.1下载自己所需的版本(7.0): http://tomcat.apache.org/do...
    b9d84779d06c阅读 8,262评论 0 3
  • 1.桶排序特点 1.待排序数服从均匀分布;2.待排序数可分配到多个单调的部分;3..待排序数分配到哪个部分实现容易...
    土人徐阅读 683评论 0 0