This commit is contained in:
2025-01-22 13:23:52 -06:00
parent c4b4fe83fb
commit a2ad258b7c

View File

@ -103,14 +103,14 @@ void tasks::stop() {
std::vector<std::unique_ptr<std::jthread>> threads; std::vector<std::unique_ptr<std::jthread>> threads;
std::swap(threads, task_threads_); std::swap(threads, task_threads_);
std::deque<scheduled_task> tasks; std::deque<scheduled_task> task_list;
std::swap(tasks, tasks_); std::swap(task_list, tasks_);
notify_.notify_all(); notify_.notify_all();
lock.unlock(); lock.unlock();
threads.clear(); threads.clear();
tasks.clear(); task_list.clear();
} }
void tasks::task_thread() { void tasks::task_thread() {