синхронизация потоков

[Diego__]

Привет всем!

Помогите освоится с std::condition_variable. Применить хочу к нижеизложенной задаче.Не до конца пойму как это работает.

Есть таски(асинхронны к GUI потоку), которые выполняются каждый в отдельном потоке. Нужно чтобы эти таски выполнялись последовательно. Т.е. при создании таска они начинали ждать завершения уже выполняющегося таска. Тут все просто. Ставлю обычный мюткекс в начале функции таски и у меня все окей. Но хочу добавить возможность отмены таска. Т.е. чтобы с GUI можно было его cancel-ьнуть. Как это сделать в рамках одной функции? ниже приведен приблизительный код.

#include <condition_variable>
#include <iostream>
#include <random>
#include <thread>
#include <mutex>
#include <queue>

static std::condition_variable	cancel_check_;
static std::mutex				run_mutex_;
static std::mutex				state_mutex;

bool cancel = false;
bool converting = false;

bool condition_func()
{
	std::lock_guard<std::mutex> guard(state_mutex);

	if (cancel)
		return true;

	if (!converting)
	{
		converting = true;
		return true;
	}

	return false;
}

void task()
{
	std::cout << "task id=" << std::this_thread::get_id() << std::endl;

	std::unique_lock<std::mutex> locker(run_mutex_);
	
	std::cout << "before wait id=" << std::this_thread::get_id() << std::endl;
	cancel_check_.wait(locker, condition_func);
	
	if (cancel)
	{
		return ;
	}
	
	std::cout << "working id=" << std::this_thread::get_id() << std::endl;
	std::this_thread::sleep_for(std::chrono::seconds(4));


	converting = false;

	std::cout << "completed id=" << std::this_thread::get_id() << std::endl;
	//locker.unlock();
	cancel_check_.notify_one();
}

void cancel_func()
{
	std::cout << "cancel" << std::endl;

	cancel = true;
	cancel_check_.notify_all();

	std::cout << "notify_all complteted" << std::endl;
}

int _tmain(int argc, _TCHAR* argv[])
{
	std::thread first_run(task);
	std::thread next_run(task);
	std::thread third_run(task);

	std::this_thread::sleep_for(std::chrono::seconds(1));

	//std::thread cancel_thread(cancel_func);


	//cancel_thread.join();
	first_run.join();
	next_run.join();
	third_run.join();
	
	return 0;
}

Получается что 2ой и 3ий потоки ждут на
std::unique_lock<std::mutex> locker(run_mutex_);
как изменить код чтобы они ждали на
cancel_check_.wait(locker, condition_func); ?