6

我想做的事情应该很容易，但我不明白......

我想做的就是在某个特定时间点在后台启动一个类的成员函数。该函数的结果也应该是“外部”可用的。所以我想在构造函数中准备任务（设置未来变量，...）并在稍后启动它。

我试图结合 std::(packaged_task|async|future) 但我没有让它工作。

这个片段不会编译，但我认为它显示了我想要做的事情：

class foo {
private:
  // This function shall run in background as a thread
  // when it gets triggered to start at some certain point
  bool do_something() { return true; }

  std::packaged_task<bool()> task;
  std::future<bool> result;

public:
  foo() : 
    task(do_something), // yes, that's wrong, but how to do it right?
    result(task.get_future()) 
  {
    // do some initialization stuff
    .....
  }
  ~foo() {}

  void start() {
    // Start Task as asynchron thread
    std::async as(std::launch::async, task); // Also doesn't work...
  }

  // This function should return the result of do_something
  bool get_result() { return result.get(); }
};

提前致谢！

4

2 回答 2

10

只需使用std::bind()：

#include <functional> // For std::bind()

foo() :
    task(std::bind(&foo::do_something, this)),
//       ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
    result(task.get_future()) 
{
    //  ...
}

此外，您在这里做错了事：

std::async as(std::launch::async, task)
//         ^^
//         Trying to declare a variable?

因为你想要的是调用std::async()函数，而不是声明一个（不存在的）类型的对象std::async()。因此，作为第一步，将其更改为：

std::async(std::launch::async, task)

但是请注意，这不足以让任务异步运行：由于std::async()返回的未来被丢弃时的奇怪行为，您的任务将始终像您同步启动它一样执行 - 返回的未来对象的析构函数将阻塞直到操作完成。(*)

要解决最后一个问题，您可以将返回的未来保存在result成员变量中（而不是分配给构造时result返回的未来std::packaged_task::get_future()）：

    result = std::async(std::launch::async, task);
//  ^^^^^^^^

(*) 我认为MSVC 忽略了这个规范，实际上是异步执行任务。因此，如果您使用的是 VS2012，您可能不会遇到这个问题。

编辑：

正如 Praetorian 在他的回答中正确提到的那样，上述内容仍然存在问题，因为packaged_task在async(). 要解决此问题，您可以task使用std::ref().

于 2013-06-24T23:07:27.677 回答
4

do_something()是一个成员函数，这意味着它需要一个隐式this指针作为第一个参数。您需要bind指向this指针，或创建一个调用do_something.

foo() : 
  task(std::bind(&foo::do_something, this)),
  result(task.get_future()) 
{}

或者

foo() : 
  task([this]{ return do_something(); }),
  result(task.get_future()) 
{}

std::async as(std::launch::async, task);

std::async是一个函数模板，而不是一个类型。所以明显的变化是

std::async(std::launch::async, task);

但这会导致另一个错误，因为在该调用的内部某处task尝试了一个副本，但std::packaged_task有一个已删除的副本构造函数。您可以通过使用来修复它std::ref，这将避免复制。

std::async(std::launch::async, std::ref(task));
于 2013-06-24T23:17:47.040 回答