concurrency: init queues when calling process_queue, use after instead of countdown