Function start_threads

example_code/item_070.py:326–330

(count, *args)

print("Example 23")
def start_threads(count, *args):
    threads = [StoppableWorker(*args) for _ in range(count)]
    for thread in threads:
        thread.start()
    return threads

def drain_queue(input_queue):
    input_queue.shutdown()