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
"""
练习：写一个服务器，可以不停的和多个客户端聊天
server端：
import socket
from threading import Thread
class Receive(Thread):
def __init__(self,addr,conversation):
super().__init__()
self.conversation=conversation
self.addr = addr
def run(self):
while True:
message = self.conversation.recv(1024).decode("utf-8")
print(self.addr, ":" + message, sep="")
server =socket.socket()
server.bind(("10.7.187.67",6666))
server.listen(100)
while True:
conversation,addr=server.accept()
#给服务器发送请求的客户端连接创建一个子线程。在子线程中处理每个请求
r1 = Receive(addr,conversation)
r1.start()
client端：
import socket
client=socket.socket()
client.connect(("10.7.187.149",9001))
while True:
message =input("自己：")
client.send(message.encode("utf-8"))
练习：下载所有的头像图片到本地
import requests
import json
import re
import threading
def download(url:str):
image_data=requests.get(url).content
file_name=url.split("/")[-1]
with open("images/"+file_name,"wb")as f:
f.write(image_data)
url1 ="https://www.apiopen.top/satinApi?type=1&page=1"
response =requests.get(url1)
json1 =response.json()
data =json1["data"]
for dict1 in data:
#拿到一个图片地址，就为他创建一个线程对象，用来在子线程中下载这种图片
t=threading.Thread(target=download,args=(dict1["profile_image"],))
# t.start()
# print("下载完成")
# with open("files/a.json","w",encoding="utf-8")as f:
# f.write(json.dumps(json1,ensure_ascii=False))
url1 ="https://www.apiopen.top/satinApi?type=1&page=1"
response =requests.get(url1)
text =response.text
re_str =r'"profile_image":(.+?),'
result =re.findall(re_str,text)
print(result)
# result =re.findall(re_str,json1)
# print(result)
