1⃣️多线程

每一程序在运行的时候(进程)系统都会为这个进程创建一个线程，这个线程叫做主线程
程序员自己创建的线程叫做子线程
多个任务在一个线程中是按顺序一个一个执行的(线程的串行)
多个线程的任务同时执行

import time
from random import randint
import datetime


def download(file):
    print(datetime.datetime.now(), '开始下载:%s' % file)

    # sleep(时间): 将当前线程阻塞指定的时间(停指定的时间，然后再往后执行)
    # 时间单位是秒
    time.sleep(randint(5, 10))
    print(datetime.datetime.now(), '%s下载完成' % file)

"""
python通过threading标准库来支持多线程

"""
import threading


# download('越狱')
# current_thread()获取当前线程
print(threading.current_thread())
# 1.创建一个线程对象
"""
Thread(target=, args=)
target:需要传一个需要在自线程中执行的函数(类型是function的变量)
args:在自线程中调用target对应的函数的时候，该传什么参数.类型是元祖
"""
t1 = threading.Thread(target=download, args=('阿甘正传',))
t2 = threading.Thread(target=download, args=('海潮之声',))
# 2.让自线程去执行任务
t1.start()
t2.start()
print('1----')

常用线程创建

创建方式1：
直接通过Thread类创建对象，将需要在自线程中执行的函数作为target参数传进去
创建线程方式2：
a.写一个自己的类去继承Thread类
b.实现当前类的run方法，run中的任务就是在子线程中执行的任务
c.创建当前类的对象，就是线程对象。然后调用stat()去执行线程中的任务

# 1.创建线程类
import threading
import datetime
import time
import random


class DownLoadThread(threading.Thread):
    """下载线程类"""
    def __init__(self, name):
        super().__init__()
        self.name = name

    def run(self):
        # 注意；如果需要给run方法中传数据，通过当前类的属性来传
        print('%s开始下载' % self.name, datetime.datetime.now())
        time.sleep(random.randint(1, 5))
        print(self.name, '下载完成')

# 2.创建线程对象


d1 = DownLoadThread('s')
d2 = DownLoadThread('1')
# 通过start去执行run中的任务
"""
注意：如果直接调用run方法，run中的任务不会再当前的自线程中执行
"""
# d1.run()
d1.start()
d2.start()

3⃣️使用线程实现服务器与客户端的链接

服务器

import threading


class ConversationThread(threading.Thread):
    def __init__(self, conversation:socket.socket, addr):
        super().__init__()
        self.conversation = conversation
        self.addr = addr

    def run(self):
        while True:
            message_re = self.conversation.recv(1024).decode('utf-8')
            print(message_re, self.addr[0])

            self.conversation.send(('我来了！%s' % self.addr[0]).encode('utf-8'))


def create_server():
    server = socket.socket()
    server.bind(('10.7.156.144', 8091))
    server.listen(100)

    while True:
        # 会阻塞线程
        conversation, addr = server.accept()

        # 创建处理这个请求对应的子线程

        t = ConversationThread(conversation, addr)
        t.start()


create_server()

客户端

import socket
client = socket.socket()

client.connect(('10.7.156.144', 8091))

while True:
    messgae = input('>>>')
    client.send(messgae.encode('utf-8'))

    mesage_re = client.recv(1024).decode('utf-8')
    print(mesage_re)