C ++:通过承诺packaged_task

c++: packaged_task via promises

本文关键字:packaged task 承诺      更新时间:2023-10-16

我正在尝试使用promises将packaged_task实现为模板类。

我的编译错误说我引用了一个已删除的函数。 我怀疑我需要实现复制和/或移动语义,但我对如何以及从哪里开始感到困惑。 任何建议都非常感谢:

#include "stdafx.h"
#include <iostream>
#include <future>
#include <functional>
#include <thread>
using namespace std;
//Base case
template<class>
class promised_task;
//Templated class
template<class Ret, class...Args>
class promised_task<Ret(Args...)> {
public:
//Constructor
//Takes a function argument that is forwarded to fn member
template<class F>
explicit promised_task(F&& f) :fn(f){}
//get_future member function:
future<Ret> get_future(){
return prom.get_future();
}
//Set value
void operator()(Args&&...args){
prom.set_value(fn(forward<Args>(args)...));
}
private:
//Promise member
promise<Ret> prom;
//Function member
function<Ret(Args...)> fn;
};

//Sample function from cplusplus.com
int countdown(int from, int to){
for (int i = from; i != to; --i){
cout << i << endl;
this_thread::sleep_for(chrono::seconds(1));
}
cout << "Lift off!" << endl;
return from - to;
}
//Verification function also from cplusplus.com
int main(){
promised_task<int(int, int)>tsk(countdown);
future<int>ret = tsk.get_future();
thread th(move(tsk), 10, 0);
int value = ret.get();
cout << "The countdown lasted for " << value << " seconds." << endl;
th.join();
cout << "Press any key to continue:" << endl;
cin.ignore();
return 0;
}
thread th(move(tsk), 10, 0)

我猜这是产生错误的行。

加:

promised_task(promised_task&& o):
prom(std::move(o).prom), fn(std::move(o).fn)
{}

promised_task以手动写入移动 CTOR。 C++11 要求编译器为您编写上述移动构造函数(或一个等效函数)。 MSVC2013 不是兼容的 C++11 编译器。

错误是抱怨它无法通过promised_task(promised_task const&)移动promised_task,被隐式删除,因为promise没有复制构造函数。 编译器应该编写promised_task(promised_task&&),但它不是 C++11 编译器(不是真的),所以它没有,并且您会收到有关缺少复制构造函数的错误。

尝试移动类型时,如果缺少移动操作,则会隐式调用 copy。 如果复制已删除/不可能/无法访问,则会收到有关无法复制类型的错误。

请注意,MSVC2015正在修复该缺陷。 C++11 的MSVC2015实现中剩下的一大漏洞是Microsoft所说的"表达式 SFINAE",以及连锁效应(库组件不符合合规性,因为它需要它来实现它)。

在最近关于 C++11 合规性的沟通中,他们表示他们计划在MSVC2015周期的某个时候为最终消费者(不是测试版)发布该更新,但在下一个主要版本之前不启用被阻止的库功能(以避免违反 ODR)。