|
|
@@ -64,6 +64,7 @@ void ThreadPool::ThreadFunc(ThreadPool *const thread_pool) { |
|
|
if (thread_pool->is_stoped_ && thread_pool->tasks_.empty()) { |
|
|
if (thread_pool->is_stoped_ && thread_pool->tasks_.empty()) { |
|
|
return; |
|
|
return; |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
task = std::move(thread_pool->tasks_.front()); |
|
|
task = std::move(thread_pool->tasks_.front()); |
|
|
thread_pool->tasks_.pop(); |
|
|
thread_pool->tasks_.pop(); |
|
|
} |
|
|
} |
|
|
|