[C++知识库]C++线程编程-future和packaged_task任务包

// packaged_task<>模板
// 可以将可调用对象和参数封装起来，并将它们和future绑定
// 这样，只要某一个工作完成了，和它绑定的future就变成了就绪状态
// 可以用做线程池的构建，用它实现多任务队列
// 但是任务包（packaged_task）只适合用于一个简单函数的表达式调用，结果也是只来自这个函数。
// 如果一个任务，无法用一个简单的函数表示，或者结果需要来自不同的任务，任务包就很难胜任，
// 就需要第三种创建future的方式：promise

/* 下面例子，使用packaged_task<> 在gui线程上运行代码，实现任务传递 */

#include <deque>
#include <mutex>
#include <future>
#include <thread>
#include <utility>  // 提供move支持的头文件
using namespace std;
mutex mut;

// 这里的任务都是最简单的函数，参数为空，返回值为void，如果有返回值会被丢弃
// 可以使用特定的函数签名
deque<packaged_task<void()>> tasks; // 任务队列
bool gui_shutdown_message_received();
void get_and_process_gui_message();

// gui线程函数
void gui_thread()
{
    // 这个函数一直循环，直到收到gui停止的消息
    while (!gui_shutdown_message_received())
    {
        // 反复轮询待处理的GUI消息
        get_and_process_gui_message();
        packaged_task<void()> task;
        // 限定作用域
        {
            // 加锁取任务
            lock_guard<mutex> lk(mut);
            if(tasks.empty())
            {
                continue;
            }
            // 取出第一个任务
            task = move(tasks.front());
            // 把任务从任务池弹出
            tasks.pop_front();
            // 离开作用域自动解锁
        }
        task(); // 执行这个函数任务，此时，与这个任务对应的future变成就绪状态
    }
}

// 启动一个线程，运行这个函数
thread gui_bg_thread(gui_thread);

// 发布任务
template<typename Func>
future<void> post_task_for_gui_thread(Func f)
{
    // 利用所提供的可调用对象，创建一个任务包
    packaged_task<void()> task(f);
    // 从任务包里获取future
    future<void> res = task.get_future();
    // 加锁
    lock_guard<mutex> lk(mut);
    // 将任务推送到任务池，给gui线程函数去做
    tasks.push_back(move(task));
    // 返回待就绪的future
    return res;
    // 离开作用域，自动解锁
}