| 12345678910111213141516 |
- import logging
- from queue import Queue
- from bnet_retriever.producer import Producer, Consumer
- logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(module)s - %(levelname)s - %(message)s')
- if __name__ == '__main__':
- id_queue = Queue()
- producer = Producer(id_queue)
- consumer_list = [Consumer(id_queue) for i in range(5)]
- producer.start()
- for i in consumer_list:
- i.start()
- producer.join()
- for i in consumer_list:
- i.join()
|