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)
