def init_queue_with_item(queue, item=None): # drain out queue while queue.qsize() > 0: queue.get() if item: queue.put(item)