多线程

1.耗时操作

1.1耗时操作放到主线程中的问题：

耗时操作放到主线程中，会阻塞线程

多个耗时操作都放到一个线程中执行，最终执行的时间是两个耗时操作的时间和。

1.2怎么解决问题

使用多个线程

2.多线程技术

python内置的threading模块，可以支持多线程

所有的进程默认都有一个线程，一般叫这个线程为主线程，其他的线程叫子线程，如果想要在进程中添加其他的线程，就创建线程对象

def download(file,times):
    print('开始下载',file)
    time.sleep(times)
    print(file,'下载结束')
if __name__ == '__main__':
    #1.创建线程对象
    # target:需要在子线程中执行的函数的名字  args:调用函数的实参列表(参数类型是列表)  返回值:线程对象
    t1 = threading.Thread(target=download,args=['爱情公寓',10])
    #2.在子线程中执行任务
    t1.start()
    t2 = threading.Thread(target=download,args=['爱情公寓1',5])
    t2.start()
    # download('爱情公寓')
    # download('狄仁杰')
    print('===')

结果为：

开始下载 爱情公寓
开始下载 爱情公寓1
===
爱情公寓1 下载结束
爱情公寓 下载结束

3.多线程技术2

方式2：写一个自己的线程类
a 写一个类，继承自Thread类
b 重写run方法，在里面规定需要在子线程中执行的任务
c 在子线程中执行的任务对应的功能，如果需要参数，通过类的对象属性来传值

from threading import Thread
from requests import request
import re
#下载数据
class DownloadThread(Thread):
    '''下载类'''
    def __init__(self,file):
        super().__init__()
        self.filepath = file
    def run(self):
        '''run方法 '''
        '''
        1.写在这个方法的内容就在子线程中执行的内容
        2.这个方法不要直接调用
        '''
        print('开始下载')
        response = request('GET',self.filepath)
        data = response.content

        #获取文件后缀
        suffix = re.search(r'\.\w+$',self.filepath).group()
        with open ('abcd'+suffix,'wb') as f:
            f.write(data)
        print('下载完成...')
if __name__ == '__main__':
    print('====')
    t1 = DownloadThread('http://yuting.local/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('!!!!')

4.多线程应用

import socket
from threading import Thread


class CoversationThread(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.117', 8080))
    server.listen(512)

    while True:

        conversation, address = server.accept()
        t = CoversationThread(conversation, address)
        t.start()
        # while True:
        #     conversation.send('你好！'.encode())
        #     print(conversation.recv(1024).decode(encoding='utf-8'))

import socket

if __name__ == '__main__':
    client = socket.socket()
    client.connect(('10.7.181.117', 8080))
    while True:
        print(client.recv(1024).decode(encoding='utf-8'))
        message = input('>>>')
        client.send(message.encode())