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也会阻塞线程，阻塞到对应的子线程中任务执行完为止
