You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
50 lines
1.2 KiB
50 lines
1.2 KiB
11 months ago
|
import threading
|
||
|
|
import time
|
||
|
|
import logging
|
||
|
|
import random
|
||
|
|
import queue
|
||
|
|
|
||
|
|
logging.basicConfig(level=logging.DEBUG,
|
||
|
|
format='(%(threadName)-9s) %(message)s',)
|
||
|
|
|
||
|
|
BUF_SIZE = 10
|
||
|
|
q = queue.Queue(BUF_SIZE)
|
||
|
|
|
||
|
|
class HiloProductor(threading.Thread):
|
||
|
|
def __init__(self,name=None):
|
||
|
|
super(HiloProductor,self).__init__()
|
||
|
|
self.name = name
|
||
|
|
|
||
|
|
def run(self):
|
||
|
|
while True:
|
||
|
|
if not q.full():
|
||
|
|
item = random.randint(1,10)
|
||
|
|
q.put(item)
|
||
|
|
logging.debug('Insertando "' + str(item)
|
||
|
|
+ '" : ' + str(q.qsize()) + ' elementos en la cola')
|
||
|
|
time.sleep(random.random())
|
||
|
|
return
|
||
|
|
|
||
|
|
class HiloConsumidor(threading.Thread):
|
||
|
|
def __init__(self,name=None):
|
||
|
|
super(HiloConsumidor,self).__init__()
|
||
|
|
self.name = name
|
||
|
|
return
|
||
|
|
|
||
|
|
def run(self):
|
||
|
|
while True:
|
||
|
|
if not q.empty():
|
||
|
|
item = q.get()
|
||
|
|
logging.debug('Sacando "' + str(item)
|
||
|
|
+ '" : ' + str(q.qsize()) + ' elementos en la cola')
|
||
|
|
time.sleep(random.random())
|
||
|
|
return
|
||
|
|
|
||
|
|
p = HiloProductor(name='productor')
|
||
|
|
p2 = HiloProductor(name='productor2')
|
||
|
|
|
||
|
|
c = HiloConsumidor(name='consumidor')
|
||
|
|
|
||
|
|
p.start()
|
||
|
|
p2.start()
|
||
|
|
c.start()
|