1.耗时操作
- 一个线程默认有一个线程，这个线程叫主线程，默认情况下所有的任务（代码）都是在主线程中执行的
import time,datetime
def download(film_name):
print("开始下载%s"%film_name,datetime.datetime.now())
time.sleep(5)#程序执行到这个地方，线程会阻塞（停5s），再执行后面的代码
print("%s下载结束"%film_name,datetime.datetime.now())
if __name__ == '__main__':
download("喜洋洋与灰太狼")
download("花园宝宝")
2.多线程
- python中提供了threading模块
默认创建的线程叫主线程，其他的线程叫子线程。如果希望代码在子线程中执行，必须手动创建线程对象。
import threading
import time,datetime
def download(film_name):
print("开始下载%s"%film_name,datetime.datetime.now())
time.sleep(5)#程序执行到这个地方，线程会阻塞（停5s），再执行后面的代码
print("%s下载结束"%film_name,datetime.datetime.now())
print(threading.current_thread())
if __name__ == '__main__':
# 1.创建线程对象
"""
Thread - 线程类
Thread(target=函数名,args=参数列表） - 直接创建线程对象 - 返回线程对象
函数名 - 需要在当前创建的子线程中执行的函数的函数变量
参数列表 - 元组，元组的元素
"""
t1 = threading.Thread(target=download,args=("海绵宝宝",))
t2 = threading.Thread(target=download,args=("花园宝宝",))
# 2.在子线程中执行任务
"""
在这儿就是在调用ti对应的线程中调用download函数，并且传递参数“海绵宝宝”
"""
t1.start()
t2.start()
#打印结果
"""
开始下载海绵宝宝 2018-11-29 19:16:21.574319
开始下载花园宝宝 2018-11-29 19:16:21.574319
海绵宝宝下载结束 花园宝宝下载结束 2018-11-29 19:16:26.5746052018-11-29 19:16:26.574605
<Thread(Thread-2, started 7488)>
<Thread(Thread-1, started 5160)>
"""
3.线程类的子类
- 创建子线程除了直接创建Thread的对象，还可以创建这个类的子类对象
- 注意：一个进程中有多个线程，进程会在所有的线程结束才会结束；
线程中的任务执行完了线程就结束了
from threading import Thread,current_thread
#1.声明一个类继承Thread
class DownloadThread(Thread):
def __init__(self,file_name):
super().__init__()
self.file_name =file_name
#2.重写run方法
def run(self):
#这个方法中的代码会在子线程当中执行
print("开始下载：%s"%self.file_name)
print(current_thread())
# 3.创建线程对象
d1=DownloadThread("滴滴滴")
d1.start()
d2 =DownloadThread("啊啊啊")
d2.start()
# d1.run()#直接调用run方法，会在主线程中执行
"""
打印结果：
开始下载：滴滴滴
<DownloadThread(Thread-1, started 6960)>
开始下载：啊啊啊
<DownloadThread(Thread-2, started 6432)>
"""
4.join
- 线程对象.join（） - 等待线程中的任务执行完成
from threading import Thread
import time,datetime,random
class Download(Thread):
def __init__(self,file_name):
super().__init__()
self.file_name=file_name
def run(self):
print("开始下载%s"%self.file_name)
a=random.randint(5,12)
time.sleep(a)
print("%s下载结束"%self.file_name,"耗时%d秒"%a)
if __name__ == '__main__':
t1 =Download("花园宝宝")
t2 =Download("海绵宝宝")
time1 =time.time()
t1.start()
t2.start()
t1.join()
t2.join()
time2 =time.time()
print(time2-time1)
"""
打印结果：
开始下载花园宝宝
开始下载海绵宝宝
花园宝宝下载结束 耗时10秒
海绵宝宝下载结束 耗时11秒
耗时： 11.00162935256958
"""
5.数据共享
- 注意：当多个线程同时对同一个数据操作的时候，可能会出现数据混乱
多个线程对一个数据进行操作，一个线程将一个数据读出来，还没来得及存进去，
另一个线程又去读了，这个时候就可能产生数据安全隐患
解决方案：加锁
Thread - 线程类（创建子线程）
Lock - 锁类 （创建锁对象）
import time,threading
class Account(object):
def __init__(self,balance,name):
self.balance=balance
self.name =name
self.lock =threading.Lock()#创建锁对象
def save_money(self,num):
"""存钱"""
self.lock.acquire()#加锁
print("开始存钱")
old_balance=self.balance
time.sleep(5)
self.balance=old_balance+num
print("存钱成功")
self.lock.release()#解锁
def pay_money(self,num):
"""取钱"""
self.lock.acquire() # 加锁
print("开始取钱")
old_balance = self.balance
time.sleep(5)
self.balance = old_balance - num
print("取钱成功")
self.lock.release() # 解锁
a1 =Account(1000,"小明")
#支付宝存钱
t1 =threading.Thread(target=a1.save_money,args=(1000,))
#银行卡取钱
t2 =threading.Thread(target=a1.pay_money,args=(500,))
t1.start()
t2.start()
t1.join()
t2.join()
print("余额:",a1.balance)
"""
打印结果：
开始存钱
存钱成功
开始取钱
取钱成功
余额: 1500
"""
6.从网络中用多线程下载图片
import threading
import time,datetime
import requests
def download(url:str):
'''下载函数'''
image_data = requests.get(url).content
file_name = url.split('/')[-1]
with open('image/'+file_name,'wb') as f:
f.write(image_data)
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
response = requests.get(url)
json = response.json()
print(json)
datas = json['data']
for dict1 in datas:
print(dict1['profile_image'])
#拿到一个图片地址，就为他创建一个线程对象，用子线程下载
t1 = threading.Thread(target=download,args=(dict1['profile_image'],))
t1.start()
print('下载完成')
#正则表达式
import re
url = 'https://www.apiopen.top/satinApi?type=1&page=1'
response = requests.get(url)
text = response.text
all_profile_image = re.findall(r'"profile_image":"(.+?)",',text)
print(all_profile_image)
for image_url in all_profile_image:
t1 = threading.Thread(target=download,args=(image_url,))
t1.start()
print('打印完成')
