1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
|
import threading
import time
import random
mutex = threading.Semaphore(1)
elementos = threading.Semaphore(0)
buffer = []
class Evento:
def __init__(self):
self.ident = random.random()
print "Generando evento %s" % self.ident
time.sleep(self.ident)
def process(self):
print "Procesando evento %s" % self.ident
def productor():
while True:
event = Evento()
mutex.acquire()
buffer.append(event)
mutex.release()
elementos.release()
def consumidor():
while True:
elementos.acquire()
mutex.acquire()
event = buffer.pop()
mutex.release()
event.process()
threading.Thread(target=productor, args=[]).start()
threading.Thread(target=consumidor, args=[]).start()
|