removed use of std::mutex. Now using lock-free concurrent_queue