会python真的可以为所欲为0(回)
353天前
这里还有人吗1(回)
538天前这里还有人吗0(回)
538天前
每天面对着电脑屏幕，敲打键盘。我所面对的并不只是代码，而是一种生活方式。0(回)
762天前到处都是羊，不想上班0(回)
842天前
鸽子
0(回)
847天前import threading |
import logging |
import random |
FORMAT = "%(asctime)s %(threadName)s %(thread)d %(message)s" |
logging.basicConfig(format=FORMAT, level=logging.INFO) |
class Dispatcher: |
def __init__(self): |
self.data = None |
self.event = threading.Event() |
self.cond = threading.Condition() |
def produce(self, total): |
for _ in range(total): |
data = random.randint(0,100) |
logging.info(data) |
with self.cond: |
self.data = data |
# self.cond.notify_all() |
self.cond.notify(2) |
# self.send.set() |
self.event.wait(1) |
self.event.set() |
def consume(self): |
while True: |
with self.cond: |
# self.send.wait() |
self.cond.wait() #阻塞等通知 |
data = self.data |
logging.info('receive {}'.format(data)) |
# self.data = None |
# self.send.clear() |
# self.event.wait(0.5) |
d = Dispatcher() |
p = threading.Thread(target=d.produce, args=(10,), name='producer') |
for _ in range(5): #广播1对5 |
c = threading.Thread(target=d.consume, name='consumer') |
c.start() |
p.start() |
