#pragma once
#include <thread>
#include <iostream>
#include <mutex>
#include <condition_variable>
#include <functional>

using namespace std;



class BaseThread
{
public:
	enum RunningState
	{
		START = 0,
		PAUSE,
		WAIT,
		STOP
	};
	
	BaseThread();
	~BaseThread() = default;
	
	// 开启线程
	void ThreadStart();
	// 暂停线程
	void ThreadPause();
	// 终止线程
	void ThreadStop();
	// 得到线程状态
	RunningState GetRunningState();
	// 添加任务
	bool AddTask(function<bool()> func);

protected:
	void Run();
	// 执行任务，主要是任务队列中取任务和执行任务的操作
	void TaskAction();
	// 挂起等待
	void WaitIfPaused();


private:
	RunningState m_state;			// 线程状态
	unique_ptr<thread> m_thread;	// 包裹智能指针的线程
	function<bool()> execFunc;		// 当前执行任务
	mutex mtx;						// 互斥量
	condition_variable cond;		// 主动暂停条件变量
	condition_variable cond_taskEmpty;	// 当前任务空变量
	condition_variable cond_taskFull;	// 当前任务满变量
};