Changed to concurrent_queu