多线程类似于同时执行多个不同程序,可以将耗时任务搁置到后台运行, 提高CPU利用率
python中多线程的使用方法:
python内置的threading模块,可以支持多线程
所有的进程默认都有一个线程(一般叫这个线程为主线程),其他的线程叫子线程
如果想要在进程中添加其他的线程,就创建线程对象
一、直接通过threading模块创建一个多线程对象
import threading
import time
def download(file, time1):
print('开始下载',file)
time.sleep(time1)
print(file, '下载结束')
if __name__ == '__main__':
print('abc')
# 1.创建线程对象
"""
target: 需要在子线程中执行的函数
args: 调用函数的实参列表(参数类型是列表)
返回值: 线程对象
"""
t1 = threading.Thread(target=download, args=['爱情公寓', 10])
# 2.在子线程中执行任务
t1.start()
t2 = threading.Thread(target=download, args=['狄仁杰', 5])
t2.start()
# download('爱情公寓')
# download('狄仁杰')
print('=====')
# t3 = threading.Thread(target=input, args=['>>>'])
# t3.start()
value = input('>>>')
print('!!!!')
二、写一个自己的线程类
- 写一个类,继承自Thread类
- 重写run方法,在里面规定需要在子线程中执行的任务
- 实现在子线程中执行的任务对应的功能,如果需要参数,通过类的对象属性来传值
from threading import Thread
import requests
import re
# 下载数据
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('./abc'+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()
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('!!!!!')
补充:
join()函数
如果一个任务想要在另外一个子线程中的任务执行完成后再执行,就在当前任务前用子线程对象调用join方法
所以join也会阻塞线程,阻塞到对应的子线程中任务执行完为止
from threading import Thread,currentThread
import time
from random import randint
class Download(Thread):
def __init__(self, file):
# 这儿父类的init方法必须调用,否则当前这个创建的对象中就没有新的线程
super().__init__()
self.file = file
def run(self):
print(currentThread())
print('开始下载:%s' % self.file)
time.sleep(randint(5, 10))
print('%s下载结束' % self.file)
if __name__ == '__main__':
# time.time(): 获取当前时间-时间戳
start_time = time.time()
t1 = Download('最强Z.mp4')
t1.start()
t2 = Download('最强A.mp4')
t2.start()
print('====')
# 获取当前线程
"""
主线程: MainThread
子线程: Thread-数字(数字从1开始。)
"""
print(currentThread())
# 如果一个任务想要在另外一个子线程中的任务执行完成后再执行,就在当前任务前用子线程对象调用join方法
# 所以join也会阻塞线程,阻塞到对应的子线程中任务执行完为止
t1.join()
# t2.join()
end_time = time.time()
print('总共消耗时间:%.2f' % (end_time - start_time))
网友评论