#!/usr/bin/env python # -*- coding: utf-8 -*- import time from threading import Thread, Event import random items = [] event = Event() class Consumer(Thread): def __init__(self, items, event): Thread.__init__(self) self.items = items self.event = event def run(self): while True: time.sleep(2) self.event.wait() item = self.items.pop() print("Consumer notify: %d poped from list by %s" %(item, self.name)) class Producer(Thread): def __init__(self, items, event): Thread.__init__(self) self.items = items self.event = event def run(self): global item for i in range(10): time.sleep(2) item = random.randint(0, 256) self.items.append(item) print ("Producer nofity: item N %d appended to list by %s" % (item, self.name)) print ("Producer notify: event set by %s " % self.name) self.event.set() print("Produce notify: event clear by %s\n" % self.name) self.event.clear() if __name__ == "__main__": producer = Producer(items, event) consumer = Consumer(items, event) producer.start() consumer.start() producer.join() consumer.join()
时间: 2024-10-14 15:39:21