Changed to concurrentqueue with blocks