01子线程对象
import time
from datetime import datetime
# python多线程技术对应的模块
import threading
"""
默认情况下，一个进程有且只有一个线程，这个线程叫主线程
threading模块中的Thread类就是线程类，这个类的对象就是线程对象，一个线程对象对应一个子线程。
（需要一个子线程就创建一个Thread类的对象）
"""
def download(file):
print('%s开始下载' % file, datetime.now())
# sleep(时间) - 程序执行到这个位置等待指定的时候再接着往后面执行
time.sleep(10)
print('%s下载结束' % file, datetime.now())
def main():
print('程序开始')
# 1.在主线程中下载三个电影（总耗时30秒）
# download('枪王之王.mp4')
# download('开国大典')
# download('黄金国.mp4')
# 2.在三个子线程中同时下载三个电影
"""
Thread(target= , args= ) - 创建子线程对象
说明：
target - Function, 需要传一个函数（这个函数中的内容会在子线程中执行）
args - target对应的函数的参数
当通过创建好的子线程对象调用start方法的时候，会自动在子线程中调用target对应的函数，并且将args中的值作为实参
"""
# 创建线程对象
t1 = threading.Thread(target=download, args=('枪王之王.mp4', ))
t2 = threading.Thread(target=download, args=('开国大典.mp4', ))
t3 = threading.Thread(target=download, args=('黄金国.mp4',))
# 开始执行t1对应的子线程中的任务（实质就是在子线程中调用target对应的函数）
t1.start()
t2.start()
t3.start()
# 线程对象调用join方法，会导致join后的代码在线程中的任务结束后才执行
t1.join()
print('下载结束！')
print('===================')
if __name__ == '__main__':
main()
02Thread子类
import threading
import time
from datetime import datetime
import requests
import re
"""
可以通过写一个类继承Thread类，来创建属于自己的线程类。
1.声明类继承Thread
2.重写run方法。这个方法中的任务就是需要在子线程中执行的任务
3.需要线程对象的时候，创建当前声明的类的对象；然后通过start方法在子线程中去执行run方法中的任务
"""
class DownloadImageThread(threading.Thread):
def __init__(self, url):
super().__init__()
self.url = url
def run(self):
print('下载图片开始时间：', datetime.now())
response = requests.get(self.url)
result = response.content
file_name = re.split(r'/', self.url)[-1]
with open('files/'+file_name, 'wb') as f:
f.write(result)
print('下载图片结束时间：', datetime.now())
class DownloadThread(threading.Thread):
"""下载类"""
def __init__(self, file):
super().__init__()
self.file = file
def run(self):
print('开始下载：'+self.file)
print('run:', threading.current_thread())
time.sleep(10)
print('%s下载结束' % self.file)
# time.sleep(10)
# print('%s下载结束' % file, datetime.now())
def main():
# 获取当前线程
print(threading.current_thread())
t1 = DownloadThread('沉默的羔羊.mp4')
t2 = DownloadThread('恐怖游轮.mp4')
# 调用start的时候会自动在子线程中调用run方法
t1.start()
t2.start()
# 注意：如果直接用对象调用run方法，run方法中的任务会在主线程执行
# t1.run()
t3 = DownloadImageThread('https://image.haha.mx/2015/12/04/middle/2082175_c5c3cc05eb73e4023149e663475d3ab4_1449192201.gif')
t3.start()
if __name__ == '__main__':
main()
03join
from threading import Thread
import requests
import re
import time
class DownloadThread2(Thread):
"""下载类"""
def __init__(self, file, time):
super().__init__()
self.file = file
self.time = time
def run(self):
print('开始下载:'+self.file)
# t = randint(5, 10)
time.sleep(self.time)
print('%s下载结束, 总共耗时:%ds' % (self.file, self.time))
class DownloadImageThread(Thread):
def __init__(self, url):
super().__init__()
self.url = url
def run(self):
# 开始下载
file_name = re.split(r'/', self.url)[-1]
print(file_name)
print('%s开始下载' % file_name)
response = requests.get(self.url)
content = response.content
with open('images/'+file_name, 'bw') as f:
f.write(content)
print('%s下载结束' % file_name)
def creat_thread():
t1 = DownloadThread2('电影1', 6)
t2 = DownloadThread2('电影2', 4)
t1.start()
t2.start()
# 线程对象调用join方法，会导致join后的代码会在线程中的任务结束后才执行
t1.join()
t2.join()
print('电影下载结束!')
def main():
# t1 = DownloadImageThread('https://image.haha.mx/2015/12/04/middle/2082175_c5c3cc05eb73e4023149e663475d3ab4_1449192201.gif')
# t1.start()
#
# t2 = DownloadImageThread('http://img4.imgtn.bdimg.com/it/u=534897622,845095650&fm=26&gp=0.jpg')
# t2.start()
t0 = Thread(target=creat_thread)
t0.start()
print('========')
for x in range(100):
time.sleep(1)
print(x)
if __name__ == '__main__':
main()
