13

私は、std::async操作を完全に非同期で開始した方がよい状況に直面しています。

future<void> MyClass::MyAsyncFunc() {
    std::future<void> f = std::async(...);
    return f;
}  // The future goes out of scope, will block.

問題は、未来を保存しないと最後に関数がブロックされることです。私はこれが起こらないことを望みます。

これstd::futureにより、関数のスコープの最後でデストラクタを呼び出すことができなくなります。

shared_ptr<future<void>> MyClass::MyAsyncFunc() {
    auto shared_ftr = std::make_shared<std::future<void>>();
    *shared_ftr = std::async([shared_ftr]() {...});
    return shared_ftr;
}

これはうまくいくでしょうか？結果を変数に保存しないとどうなりますか?

4

2 に答える 2

6

これは本格的な例です。このパターンは機能します。ブースト asio および非同期操作で広く使用しています。

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

std::shared_ptr<std::future<int>> get_task()
// std::future<int> get_task() // rely on move, future supports move
{
  auto f = std::make_shared<std::future<int>>();
  //std::future<int> f = std::async(std::launch::async, [] {
  *f = std::async(std::launch::async, [f] {
    (void) f;
    std::cout << "calculating" << std::endl;
    for (int x = 0; x < 10; ++x)
      std::this_thread::sleep_for( std::chrono::milliseconds( 200 ) );
    std::cout << "done." << std::endl;
    return 100;
  });

  return f;
}


int main(void)
{
  std::cout << "getting task" << std::endl;
  //auto f = get_task(); <-- the future is moved not copied, so there is no block here
  get_task();
  std::cout << "waiting" << std::endl;
//  f.wait(); <-- now wait for it to complete...
//  std::cout << " got: " << f.get() << std::endl;
  // Wait for the truly async task to complete...
  std::this_thread::sleep_for(std::chrono::milliseconds(3000));
}

私が表明したい唯一の懸念は、future（移動されたか経由でshared_ptr）キャプチャせずに最後に待機することです。タスクが完了する前にアプリが終了するのを止める方法はありません...

継続を確実にする他の方法がある場合、そのshared_ptrアプローチはうまく機能します。そうでなければ、動かされた未来に行きなさい、それはよりきれいです...

于 2014-08-25T09:49:26.053 に答える
2 
future<void> MyClass::MyAsyncFunc() {
  std::future<void> f = std::async(...
  return f;
} //future out of scope, will block

と

shared_ptr<future<void>> MyClass::MyAsyncFunc() {
    auto shared_ftr = std::make_shared<std::future<void>>();
    *shared_ftr = std::async([]() {...});

    return shared_ftr;
}

同等です。後者は、前者とまったく同じように機能します。

スコープ外に出る関数の未来は移動されているため、ブロックできません。ブロッキングは、表示されていない呼び出し関数で発生する可能性が最も高いです。

于 2014-08-25T09:55:42.633 に答える