***************************************************************************************模型--蹲坑(Semaphore)**********************************************************************
import threading
import time
import random
'''
---------------------
先是判断，如果没有加锁然后设置了超时时间，抛出ValueError；
循环，如果value == 0，没有加锁或在超时时间内，跳出循环；
否则，调用Condition变量wait函数等待通知或超时；
如果value不为0，跳出循环执行else里的代码，信号量-1，rc = ture，
代表可以调用release函数，最后返回rc；
信号量+1，然后调用Condition变量的notify唤醒一个线程～
剩下的_enter_和_exit_就不用说了，重写这两个方法就能直接用with关键字了
'''
s = threading.Semaphore(5) # 粪坑
class Human(threading.Thread):
def run(self):
#with s:
s.acquire() # 占坑
print("拉屎拉屎 - " + self.name + " - " + str(time.ctime()))
time.sleep(random.randrange(1, 3))
print("拉完走人 - " + self.name + " - " + str(time.ctime()))
s.release() # 走人
if __name__ == '__main__':
for i in range(10):
human = Human()
human.start()
*****************************************************************模型--公司旅游(Barrier)*****************************************************************************************************
import threading
import time
import random
'''
---------------------
BrokenBarrierError：RuntimeError的子类，当栅栏被reset()或broken时引发；
例子：公司一起去旅游
'''
class Staff(threading.Thread):
def __init__(self, barriers):
#threading.Thread.__init__(self)
super().__init__()
self.barriers = barriers
def run(self):
print("员工 【" + self.name + "】" + "出门")
time.sleep(random.randrange(1, 10))
print("员工 【" + self.name + "】" + "已签到")
self.barriers.wait()
def ready():
print(threading.current_thread().name + "：人齐，出发，出发～～～")
if __name__ == '__main__':
print("要出去旅游啦，大家快集合～")
#barrier屏障
b = threading.Barrier(10, action=ready, timeout=20)
for i in range(10):
staff = Staff(b)
staff.start()
********************************************************************模型--红绿灯(Event)*********************************************************************************************
import threading
import time
import random
'''
---------------------
判断标志是否为False，False的话进入堵塞状态，(⊙v⊙)嗯
源码就那么简单，感觉看完还是蒙圈不知道怎么用，写个简单的例子？
汽车过红绿灯的例子
'''
class CarThread(threading.Thread):
def __init__(self, event):
threading.Thread.__init__(self)
self.threadEvent = event
def run(self):
# 休眠模拟汽车先后到达路口时间
time.sleep(random.randrange(1, 10))
print("汽车 - " + self.name + " - 到达路口...")
self.threadEvent.wait()
print("汽车 - " + self.name + " - 通过路口...")
if __name__ == '__main__':
light_event = threading.Event()
# 假设有20台车子
for i in range(20):
car = CarThread(event=light_event)
car.start()
while threading.active_count() > 1:
light_event.clear()
print("红灯等待...")
time.sleep(3)
print("绿灯通行...")
light_event.set()
time.sleep(2)
*****************************************************************************************模型--生产者消费者(Condition)************************************************************************************************
# -*- coding:utf-8 -*-
import threading
import time
'''
Condition(条件变量)除了提供与Lock类似的acquire()与release()函数外，还提供了
wait()与notify()函数
1.调用threading.Condition获得一个条件变量对象；
2.线程调用acquire获得Condition对象；
3.进行条件判断，不满足条件调用wait函数，满足条件，进行一些处理改变
条件后，调用notify函数通知处于wait状态的线程，重新进行条件判断。
'''
num = 0
con = threading.Condition()
class Producer(threading.Thread):
"""生产者"""
def run(self):
global num
# 获取锁
con.acquire()
while True:
num += 1
print('生产了1个，现在有{0}个'.format(num))
time.sleep(1)
if num >= 5:
print('已达到5个，不再生产')
# 唤醒消费者
con.notify()
# 等待-释放锁；被唤醒-获取锁
con.wait()
# 释放锁
print('Producer释放锁')#没执行
con.release()
class Customer(threading.Thread):
def __init__(self, *args, **kwargs):
super().__init__(*args, **kwargs)
self.money = 7
def run(self):
global num
while self.money > 0:
# 由于场景是多个消费者进行抢购，如果将获取锁操作放在循环外(如生产者),
# 那么一个消费者线程被唤醒时会锁住整个循环，无法实现另一个消费者的抢购。
# 在循环中添加一套"获取锁-释放锁",一个消费者购买完成后释放锁，其他消费者
# 就可以获取锁来参与购买。
con.acquire()
if num <= 0:
print('没货了，{0}通知生产者'.format(self.name))
#唤醒生产者
con.notify()
#等待
con.wait()
self.money -= 1
num -= 1
print('{0}消费了1个, 剩余{1}个'.format(
threading.current_thread().name, num))
time.sleep(1)
con.release()
time.sleep(1)
print('{0}没钱了-回老家'.format(threading.current_thread().name))
if __name__ == '__main__':
p = Producer(daemon=True)
c1 = Customer(name='Customer-1')
c2 = Customer(name='Customer-2')
p.start()
c1.start()
c2.start()
c1.join()
c2.join()
*****************************************************************************模型--时间(Timer)*************************************************************************************
import threading
import time
def skill_ready():
print("!!!!!!大招已经准备好了!!!!!!")
if __name__ == '__main__':
t = threading.Timer(5, skill_ready)
t.start()
while threading.active_count() > 1:
print("======大招蓄力中======")
time.sleep(1)