0

试图与packaged_task<T>

std::asyncstd::future<T>使用类模板和方法创建一个异步执行的线程并处理我们可以访问的数据get()。

我应该知道什么是如何packaged_task<T>工作的，有什么不同std::async？

packaged_task<T>当我们调用该task(x)函数时，是否创建了与该线程相关的线程？

以代码示例：

#include <iostream>
#include <thread>
#include <future>
#include <chrono>

using namespace std::chrono;

int main()
{

    int x(0),xr(0);

    std::future<int> fdata = std::async(std::launch::async,[&](int data) mutable throw() ->
                                        int
                                        {data++;
                                        std::this_thread::sleep_for(seconds(2));
                                        return data;}
                                        ,x);

    std::packaged_task<int(int)> task([&](int data) mutable throw() ->
                                        int
                                        {data++;
                                        std::this_thread::sleep_for(seconds(2));
                                        return data;}
                                        );
    std::future<int> xrp = task.get_future();

    task(x);

    xr=fdata.get();

    std::cout<<xr<<std::endl;
    std::cout<<xrp.get()<<std::endl;

    return 0;
}
4

1 回答 1

1 
std::async(ploicy, callable, args...)

如果策略为 . 则启动一个新线程（如果资源可用）std::async::launch。

如果政策没有确定，它可能会启动或不启动。

如果策略是std::async::deferred，则不会启动。

whilestd::packaged_task包装您的可调用对象，以便可以使用新线程异步调用它

auto t1 = std::thread(std::move(taskObj), args...);
....
t1.join();

但是，如果您像在示例中那样使用它，它就不会启动新线程。它本身不会启动新线程，但可以用来执行此操作。

于 2020-05-24T02:24:27.757 回答