def consumer(e, q): while not e.is_set(): message = q.get() time.sleep(0.1) logging.debug('consume {0}'.format(message))