task_scheduler_observer クラスの拡張

概要

ワーカースレッドのスリープを制御するように、そしてスレッドがタスク・スケジューラー領域にジョインしたときや離脱したときを監視するように、task_scheduler_observer クラスが拡張されました。以前の task_scheduler_observer は、ワーカースレッドがグローバル・タスク・スケジューラーにジョインしたときと終了したときのみ監視していました。

構文

class task_scheduler_observer;

ヘッダー

#define TBB_PREVIEW_LOCAL_OBSERVER 1
#include "tbb/task_scheduler_observer.h"

メンバー

namespace tbb {
  class task_scheduler_observer {
  public:
    task_scheduler_observer( bool local = false );
    task_scheduler_observer( task_arena & a)

    // ローカル・オブザーバーに関連しないメソッドは
    // task_scheduler_observer を参照 ...

#if TBB_USE_PREVIEW_BINARY
    enum { keep_awake = false, allow_sleep = true };
    // プレビューバイナリーを使用する機能のみ
    virtual bool may_sleep() { return allow_sleep; }
#endif
  };
}

サンプル: スレッド・アフィニティーの設定

次のサンプルは、ワーカースレッドをハードウェア・スレッドに関連付けるオブザーバーのコードを示します。

class pinning_observer: public tbb::task_scheduler_observer {
public:
  affinity_mask_t m_mask; // この領域で使用する HW アフィニティー・マスク
  pinning_observer( tbb::task_arena &a, affinity_mask_t mask )
    : tbb::task_scheduler_observer(a), m_mask(mask) {
    observe(true); // オブザーバーをアクティブ化
  }
  /* オーバーライド */ void on_scheduler_entry( bool worker ) {
    set_thread_affinity(tbb::task_arena::current_thread_index(), m_mask); 
  }
  /* オーバーライド */ void on_scheduler_exit( bool worker ) { }
};

サンプル: ワーカースレッドをアクティブなまま保つ

次のサンプルは、ワーカースレッドの構築中はスリープ状態にならないようにして、オブザーバーを破棄した後にスリープを許可する、オブザーバーのコードです。このオブザーバーを使用して並列計算を継続する範囲を表すことができます。

class computation_scope: public tbb::task_scheduler_observer {
public:
  computation_scope( ) { observe(true); } // オブザーバーをアクティブ化
  /* オーバーライド */ bool may_sleep( ) {
    return keep_awake;
  }
};

void usage() {
  non_TBB_code();
  {
    computation_scope protector(); // ワーカースレッドをアクティブなまま保つ
    for(int i = 0; i < N; i++)
        tbb::parallel_for(0, M, ProcessingFunctor());
  }
  non_TBB_code();
}