implemented concurrent_queue with parallel_for.