C ++でstd :: threadを一時停止および再開するstd :: condition_variableと比較してstd :: atomicを使用するアプローチ

条件変数は、別のスレッドを条件付きで停止するかどうかを決定する場合に役立ちます。したがって、実行する必要がないことに気付いたときに待機する、常に実行されている「ワーカー」スレッドがある場合があります。

アトミックソリューションでは、UIインタラクションをワーカースレッドと同期するか、非同期で行うために非常に複雑なロジックが必要です。

一般的なルールとして、あなたのUIの応答スレッドは、ワーカースレッドから非準備状態でブロックすることはありません。

struct worker_thread {
  worker_thread( std::function<void()> t, bool play = true ):
    task(std::move(t)),
    execute(play)
  {
    thread = std::async( std::launch::async, [this]{
      work();
    });
  }
  // move is not safe.  If you need this movable,
  // use unique_ptr<worker_thread>.
  worker_thread(worker_thread&& )=delete;
  ~worker_thread() {
    if (!exit) finalize();
    wait();
  }
  void finalize() {
    auto l = lock();
    exit = true;
    cv.notify_one();
  }
  void pause() {
    auto l = lock();
    execute = false;
  }
  void play() {
    auto l = lock();
    execute = true;
    cv.notify_one();
  }
  void wait() {
    Assert(exit);
    if (thread)
      thread.get();
  }
private:
  void work() {
    while(true) {
      bool done = false;
      {
        auto l = lock();
        cv.wait( l, [&]{
          return exit || execute;
        });
        done = exit; // have lock here
      }
      if (done) break;
      task();
    }
  }
  std::unique_lock<std::mutex> lock() {
     return std::unique_lock<std::mutex>(m);
  }
  std::mutex m;
  std::condition_variable cv;
  bool exit = false;
  bool execute = true;
  std::function<void()> task;
  std::future<void> thread;
};

またはそのような。

これは、スレッドを所有しています。スレッドを繰り返し、それがであるとしてタスクを実行play()モード。あなたの場合はpause()、次の時間task()が終了、ワーカースレッドが停止します。通話が終了するplay()前に、にtask()気付かない場合pause()。

唯一の待機は、の破棄ですworker_thread。ここでは、終了する必要があることをワーカースレッドに自動的に通知し、終了するのを待機します。

手動でできる.wait()か.finalize()にも。.finalize()は非同期ですが、アプリがシャットダウンしている場合は、アプリを早期に呼び出して、メインスレッドが他の場所でクリーンアップしている間、ワーカースレッドにクリーンアップする時間を与えることができます。

.finalize() 取り消すことはできません。

コードはテストされていません。