task_arena クラス

概要

明示的なユーザー管理タスク・スケジューラー領域の表現。

構文

class task_arena;

ヘッダー

#include "tbb/task_arena.h"

説明

task_arena クラスは、タスクを共有して実行する内部タスク・スケジューラー・オブジェクトを表します。

task_arena のタスクを同時に実行するスレッド数は並列レベルにより制限されます。並列レベルはその領域にのみ影響し、以前の task_scheduler_init 仕様の影響を受けません。

タスク・スケジューラーを明示的または暗黙的に初期化する各ユーザースレッドは、暗黙の内部タスク領域オブジェクトを作成して使用します。1 つの領域にスポーンまたは追加されたタスクは、ほかの領域では実行できません。

task_arena のインスタンスは、内部表現への参照を保持しますが、その存続期間を完全には管理しません。内部表現は、タスクが含まれるか、ほかのスレッドが参照している間は破棄できません。

メンバー

namespace tbb {
    class task_arena {
    public:
        static const int automatic = implementation-defined;
        struct attach {};
        static int current_thread_index();
        task_arena(int max_concurrency = automatic, unsigned reserved_for_masters = 1);
        task_arena(const task_arena &s);
        task_arena(task_arena::attach);
        ~task_arena();
        void initialize();
        void initialize(int max_concurrency, unsigned reserved_for_masters = 1);
        void initialize(task_arena::attach);
        void terminate();
        bool is_active();
        template<typename F> void enqueue(const F& f);
        template<typename F> void enqueue(const F& f, priority_t p);
        template<typename F> void execute(F& f);
        template<typename F> void execute(const F& f);
    };
}

サンプル

次のサンプルは、同時に 2 つの paralel_for ループを実行します。1 つはスケーラブルで、もう 1 つはスケーラブルではありません。スケーラブルでないループは最大 2 スレッドに制限されるため、ほとんどのスレッドはスケーラブルなループに使用できます。特定のタスクのサブセットを待機するには、task_group を使用します。

tbb::task_scheduler_init def_init; // スレッドのデフォルトの番号を使用
tbb::task_arena limited(2);// この領域では最大 2 スレッドのみ
tbb::task_group tg;

limited.execute([&]{ // 最大 2 つのスレッドを使用
    tg.run([]{ // タスクグループで実行
        tbb::parallel_for(1, N, unscalable_work());
    });
});

// 別のジョブを上記のループと並列に実行
// スレッドのデフォルトの番号を使用可能:
tbb::parallel_for(1, M, scalable_work());

// execute() の内側でタスクグループを
// 待つようにする
// このタスクグループのタスクのみを待つ
limited.execute([&]{ tg.wait(); });