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()