(module Thread_safe_queue)