Searched refs:cleanup_threads (Results 1 – 1 of 1) sorted by relevance
196 std::vector<std::thread> cleanup_threads; in CleanupAllStreams() local198 cleanup_threads.emplace_back([this, i, cleaner] { in CleanupAllStreams()206 for (auto& th : cleanup_threads) { in CleanupAllStreams()