12

我需要经常做这样的事情：

AsyncOperation * pAsyncOperation = new AsyncOperation();
auto bindOperation = std::bind(&AsyncOperation::operator(), std::ref(*pAsyncOperation));
std::thread thread(bindOperation );
thread.join();

AsyncOperation作为任何自定义类实现（operator() 也称为函数对象）。

是否可以指示std::bind使用 astd::shared_ptr而不是 a std::ref？这将防止内存泄漏，而我不需要保持对 的引用pAsyncOperation，并且会在线程结束时自动删除AsyncOperation，即这个异步任务的结束。

编辑：我并不总是可以访问 std::thread，线程库可以是 boost::thread 甚至任何其他平台相关线程。因此，无法访问 std::async。

我的主要问题是在 std::bind 中有所有权的概念。

4

2 回答 2

14

这有效：

struct AsyncOperation {
    void operator()()
    {
        std::cout << "AsyncOperation" << '\n';
    }
};

int main() {
  std::shared_ptr<AsyncOperation>  pAsyncOperation = std::make_shared<AsyncOperation>();
  auto bindOperation = std::bind(&AsyncOperation::operator(), pAsyncOperation);
  std::thread thread(bindOperation );
  thread.join();
}

见： http: //liveworkspace.org/code/4bc81bb6c31ba7b2bdeb79ea0e02bb89

于 2012-11-07T15:51:24.923 回答
7

需要AsyncOperation动态分配吗？如果没有，我会这样做：

auto f = std::async([]{ AsyncOperation()(); });
f.wait();

除此以外：

std::unique_ptr<AsyncOperation> op(new AsyncOperation);
auto f = std::async([&]{ (*op)(); });
f.wait();

您当然可以使用std::thread，但它会提供更多问题（即其他线程中的异常处理）。std::bind也有它自己的问题，你可能会更好地结束一个 lambda。

如果您确实需要将所有权传递给其他线程，您也可以这样做：

std::unique_ptr<AsyncOperation> op(new AsyncOperation);
auto f = std::async([&](std::unique_ptr<AsyncOperation> op){ (*op)(); }, std::move(op));
f.wait();

因为 lambdas 还不支持移动类型捕获。

我希望这会有所帮助。

于 2012-11-07T15:44:44.607 回答