首先，我想为这篇冗长的帖子道歉。我想尽可能彻底。
我已经在这个问题上停留了几天，关于正确使用boost::packaged_task具有输入参数的函数的信息令人惊讶地少。
系统信息
- C++03
- 提升 1.54.0
- CMake 2.8.9
初始要求
- 我有一个由客户端、服务器和设备组成的设置。
- 客户端通过向服务器发送请求来与设备交互。
- 检查这些请求并将其路由到适当的设备。
boost::asio::io_service::strand请求是异步处理的，并且由于各种原因偶尔会排队。
- 请求被放入设备本身本地的队列中。
- 当请求被确认（不一定完成）时，它被分配一个 ID，并返回给客户端。
打包任务
在查看了boost::futures之后，我们认为boost::packaged_task完全可以满足我们的需要。但是，打包任务的实现似乎存在错误。
看起来好像 packaged_task 有几个不同的模板可供选择：
packaged_task<R>packaged_task<R()>packaged_task<R(ArgTypes)>- 我可能会错过的其他人。
为了确保我正确使用该功能，我从简单开始；使用 boost::futures 页面上的简单示例作为起点。从那里，我创建了四个简单的函数：
- int 返回，无参数。
- int 返回，带参数。
std::string返回，无参数。std::string返回，带参数。
测试功能
std::string ans("forty two");
int int_no_params()
{
return 42;
}
int int_with_params(int param)
{
return param;
}
std::string string_no_params()
{
return std::string("forty two");
}
std::string string_with_params(std::string & param) // Have tried both with and without '&'
{
return param;
}
示例 1：
int function(void)
//! Compiles and produces correct result.
{
boost::packaged_task<int()> example(int_no_params);
boost::future<int> f = example.get_future();
boost::thread task(boost::move(example));
int answer = f.get();
std::cout << "Answer to life and whatnot, in English: " << answer << std::endl;
task.join();
}
示例 2：
std::string function(void)
//! Compiles and produces correct result.
{
boost::packaged_task<std::string()> example(string_no_params);
boost::future<std::string> f = example.get_future();
boost::thread task(boost::move(example));
std::string answer = f.get();
std::cout << "string_no_params: " << answer << std::endl;
task.join();
}
示例 3：
std::string(std::string& param)没有穿线
//! Doesn't compile.
//! error: variable ‘boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)> example’ has initializer but incomplete type
{
boost::packaged_task<std::string(std::string&)> example(string_with_params);
boost::future<std::string> f = example.get_future();
example(ans);
std::string answer = f.get();
std::cout << "string_with_params: " << answer << std::endl;
}
示例 4：
使用 boost::threading
//! Doesn't compile.
//! error: variable ‘boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)> example’ has initializer but incomplete type
{
boost::packaged_task<std::string(std::string&)> example(string_with_params);
boost::future<std::string> f = example.get_future();
boost::thread task(boost::move(example), ans);
std::string answer = f.get();
std::cout << "string_with_params: " << answer << std::endl;
task.join();
}
例 5：
在 packaged_task 声明中使用扩展初始化器
//! Doesn't compile in C++03, C++11 only.
//! error: extended initializer lists only available with -std=c++11 or -std=gnu++11 [-Werror]
{
boost::packaged_task<std::string(std::string&)> example
{ boost::bind(&string_with_params, ans) };
boost::future<std::string> f = example.get_future();
boost::thread task(boost::move(example), ans);
std::string answer = f.get();
std::cout << "string_with_params: " << answer << std::endl;
task.join();
}
例 6：
线程化，使用 shared_ptr
以下使用
typedef boost::packaged_task<std::string(std::string&)> task_t;
由于无法复制打包的任务，因此绑定shared_ptr<T>::operator()到task是一个建议的解决方案，可在此处找到。
// error: invalid use of incomplete type ‘class boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>’
// error: incomplete type ‘task_t {aka boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>}’ used in nested name specifier
// boost/thread/future.hpp:1320:11: error: declaration of ‘class boost::packaged_task<std::basic_string<char>(std::basic_string<char>&)>’
{
boost::shared_ptr<task_t> example = boost::make_shared<task_t>(boost::bind(&string_with_params, ans));
boost::future<std::string> f = example->get_future();
boost::thread task(boost::bind(&task_t::operator(), example));
std::string answer = f.get();
std::cout << "string_with_params: " << answer << std::endl;
task.join();
}
例 7：
使用boost::asio::io_service和boost::bind
// 错误：无效使用不完整类型 'class boost::packaged_task(std::basic_string&)>' // 错误：嵌套名称中使用了不完整类型 'task_t {aka boost::packaged_task(std::basic_string&)>}'说明符 // boost/thread/future.hpp:1320:11: error: 'class boost::packaged_task(std::basic_string&)>'的声明</p>
{
boost::asio::io_service io_service;
boost::thread_group threads;
boost::asio::io_service::work work(io_service);
for (int i = 0; i < 3; ++i)
{
threads.create_thread(boost::bind(&boost::asio::io_service::run,
&io_service));
}
boost::shared_ptr<task_t> example = boost::make_shared<task_t>(boost::bind(&string_with_params, ans));
boost::future<std::string> f = example->get_future();
io_service.post(boost::bind(&task_t::operator(), example));
std::string answer = f.get();
std::cout << "string_with_params: " << answer << std::endl;
threads.join_all();
}
我在这里做错了什么吗？我觉得我已经对此进行了详尽的测试，但没有取得任何进展。我已经尝试了绑定、线程和任务的所有其他组合来使其正常工作，但它根本没有发生。感谢您提供的任何帮助。
最后一点：
我有一个使用期货和承诺的有效解决方案，通过使用私有函数发布到我的线程，我返回了一个有效的未来。这个问题似乎不一定是用户错误。
谢谢阅读。