2.任务包多线程并行计算

#include <future>//进程通信,获取未来的结果
#include<iostream>
#include <thread>
#include <string>
#include <chrono>//时间
#include <mutex>//互斥量
using namespace std;

//创建互斥量
mutex m;

//全局通信变量
promise<string> val;

void main()
{
    //访问外部变量[=]
    auto fun = [=](int index)->int
    {
        //加锁
        lock_guard<mutex> lckg(m);

        //显示线程id
        cout << "线程编号:" << this_thread::get_id() << "  " << index << endl;
        //等待十秒
        this_thread::sleep_for(chrono::seconds(1));

        //计算
        return index * 1024;
    };

    //获取返回值,创建任务包
    packaged_task<int(int)> pt1(fun);
    packaged_task<int(int)> pt2(fun);

    thread t1([&]() 
    {
        pt1(23); 
    });
    thread t2([&]()
    {
        pt2(26);
    });

    //开启线程,获取结果,只能获取一次
    int res1 = pt1.get_future().get();
    int res2 = pt2.get_future().get();
    int last = res1 + res2;
    cout << last << endl;

    t1.joinable();
    t2.joinable();
    t1.join();
    t2.join();
    system("pause");
}