@contextmanager<EOL>def parallel_task_queue(pool_size=multiprocessing.cpu_count()):
task_queue = TaskQueue(pool_size)<EOL>yield task_queue<EOL>task_queue.execute()<EOL>
Context manager for setting up a TaskQueue. Upon leaving the
    context manager, all tasks that were enqueued will be executed
    in parallel subject to `pool_size` concurrency constraints.