Method thread_func

extra/mariabackup/thread_pool.cc:30–50

}

void ThreadPool::thread_func(unsigned thread_num) {
	if (my_thread_init())
		die("Can't init mysql thread");
	std::unique_lock<std::mutex> lock(m_mutex);
	while(true) {
		if (m_stop)
			goto exit;
		while (!m_jobs.empty()) {
			if (m_stop)
				goto exit;
			job_t j = std::move(m_jobs.front());
			m_jobs.pop();
			lock.unlock();
			j(thread_num);
			lock.lock();
		}
		m_cv.wait(lock, [&] { return m_stop || !m_jobs.empty(); });
	}
exit:
	my_thread_end();
}