"""author = 陈俊龙"""
=============多线程技术1===============
import threading
from time import sleep
from datetime import datetime
1.主线程和子线程
默认情况下，进程有一个线程，这个线程就是主线程（主线程不需要程序员自己去写代码，是系统创建的）
默认所以的代码都是在主线程中执行的
程序员通过代码创建的线程都叫子线程。
2.创建子线程
python内置的threading模块中提供了和线程操作相关的类和方法
threading模块中有一个Thread类，这个类或者这个子类的对象就是线程对象
需要子线程的时候就创建Thread类的对象
def download(name):
print('%s开始下载%s' % (datetime.now(), name))
print(threading.current_thread())
sleep(4)
print()
print('%s:%s完成下载' % (datetime.now(), name))
# download('窃听风云')
#
# download('无间道')
3.创建线程对象
Thread(target=函数，args=实参列表) - 返回线程对象
说明：
target -
必须赋一个函数名，这个函数会在子线程中调用
args -
赋一个！元组！，元组中的元素就是调用target函数的时候需要传入的参数
4.创建三个子线程
t1 = threading.Thread(target=download, args=('无间道',))
t2 = threading.Thread(target=download, args=('窃听风云',))
t3 = threading.Thread(target=download, args=('门徒',))
5.执行子线程
线程对象.start（） - 在子线程中去调用target对应的download,并且把args的参数传入
t1.start()
t2.start()
t3.start()
6.程序的结束（进程的结束）
一个进程是否结束，是看这个进程中的每一个线程是否都结束了，一个进程才会结束
结束线程的方式：exit()，任务执行完成，或者发生异常
注意： 程序出现异常只会影响当前线程，其他线程继续工作,出现了exit()当前线程也会结束
exit()
raise RuntimeWarning
===============多线程技术2==============
import threading
from time import sleep
from datetime import datetime
1.通过创建Thread子对象创建子线程
1)声明一个类继承Thread
class DownloudThread(threading.Thread):
def __init__(self, name):
super().__init__()
self.name = name
2）实现run方法，这个方法中的代码就是会在子线程中执行的代码
def run(self) -> None:
print('%s-开始下载：%s' % (datetime.now(), self.name), threading.current_thread())
sleep(4)
print('%s-下载完成：%s' % (datetime.now(), self.name), threading.current_thread())
3）创建子类的线程对象
t1 = DownloudThread('无间道')
t2 = DownloudThread('门徒')
4）通过start去执行子线程中的任务
t1.start()
t2.start()
练习：用套接字实线一个服务器同时处理多个客户端的功能（一个服务器同时和多人聊天）
import socket
import threading
server = socket.socket()
server.bind(('10.7.160.62', 8888))
server.listen(10)
class Talk(threading.Thread):
def __init__(self, connection, address):
super().__init__()
self.connection = connection
self.address = address
def run(self) -> None:
while True:
re_mess = self.connection.recv(1024)
print(self.address, re_mess.decode())
self.connection.send('我是服务器'.encode('utf8'))
while True:
print('开始监听')
connection, adr = server.accept()
print('有新用户连接。。。。')
if connection:
t1 = Talk(connection, adr)
t1.start()
===============join方法================
from threading import *
from time import *
from datetime import *
from random import randint
class Download(Thread):
def __init__(self, name):
super().__init__()
self.name = name
def run(self) -> None:
print('%s-开始下载%s' % (datetime.now(), self.name))
t = randint(2, 5)
sleep(t)
print('%s-下载完成%s' % (datetime.now(), self.name))
d1 = Download('无间道')
d2 = Download('窃听风云')
d3 = Download('门徒')
d1.start()
d2.start()
join的使用
两个线程都结束才会执行后面print的代码
d1.join()
d2.join()
print('下载结束')
两个线程结束之后才开始这个线程：
d3.start()
========多线程技术数据安全问题==========
from threading import Thread, Lock
import time
1.加锁
1)保证一个数据一把锁：创建锁对象
2）使用数据之前加锁:锁对象.acquire()
3）保证数据使用完成后释放锁:锁对象.release()
# 数据
account = 1000
# 1.创建锁对象
lock = Lock()
def save_money(num):
print('开始存钱')
# 2.加锁（获取锁）
lock.acquire()
global account
balance = account
time.sleep(4)
account = balance + num
# 3.释放锁
lock.release()
print('余额：%s' % account)
def draw_money(num):
print('开始取钱')
lock.acquire()
global account
balance = account
if balance < num:
return '余额不足'
time.sleep(4)
account = balance - num
lock.release()
print('余额：%s' % account)
t1 = Thread(target=save_money, args=(1000,))
t2 = Thread(target=draw_money, args=(500,))
t2.start()
t1.start()
