run.py 476 B

12345678910111213141516
  1. import logging
  2. from queue import Queue
  3. from bnet_retriever.producer import Producer, Consumer
  4. logging.basicConfig(level=logging.INFO, format='%(asctime)s - %(module)s - %(levelname)s - %(message)s')
  5. if __name__ == '__main__':
  6. id_queue = Queue()
  7. producer = Producer(id_queue)
  8. consumer_list = [Consumer(id_queue) for i in range(5)]
  9. producer.start()
  10. for i in consumer_list:
  11. i.start()
  12. producer.join()
  13. for i in consumer_list:
  14. i.join()