PPL における取り消し処理
このドキュメントでは、並列パターン ライブラリ (PPL: Parallel Patterns Library) での取り消し処理の役割、並列処理を取り消す方法、および並列処理の取り消しを判定する方法について説明します。
Note
ランタイムは例外処理を使用して取り消し処理を実装します。 これらの例外をコードでキャッチまたは処理しないでください。 さらに、タスクの関数本体では例外セーフなコードを作成することをお勧めします。 たとえば、Resource Acquisition Is Initialization (RAII) パターンを使用すると、タスクの本体で例外がスローされたときに、リソースを正しく処理することができます。 取り消し可能なタスクで RAII パターンを使用してリソースをクリーンアップする完全な例については、「チュートリアル: ユーザー インターフェイス スレッドからの処理の除去」を参照してください。
重要なポイント
取り消し処理は他の処理と連携して行われ、取り消し処理を要求するコードと取り消し処理に応答するタスクの間に連携が必要です。
可能な場合は、キャンセル トークンを使用して処理を取り消します。 concurrency::cancellation_token クラスで、キャンセル トークンを定義します。
キャンセル トークンを使用する場合、concurrency::cancellation_token_source::cancel メソッドを使用して取り消し処理を開始し、concurrency::cancel_current_task 関数を使用して取り消し処理に応答します。 concurrency::cancellation_token::is_canceled メソッドを使用して、他のタスクが取り消しを要求しているかどうかを確認します。
取り消し処理はすぐに実行されません。 タスクまたはタスク グループが取り消される場合、新しい処理は開始されませんが、アクティブな処理では取り消し状態をチェックし、取り消し処理に応答する必要があります。
値ベースの継続は、継続元タスクのキャンセル トークンを継承します。 タスク ベースの継続は、継続元タスクのトークンを継承しません。
cancellation_tokenオブジェクトを受け取るコンストラクターまたは関数を呼び出し、その操作を取り消し可能にしない場合は、concurrency::cancellation_token::none メソッドを使用します。 また、concurrency::task コンストラクターまたは concurrency::create_task 関数にキャンセル トークンを渡さない場合、そのタスクは取り消し可能になりません。
目次
並列作業ツリー
PPL は、細かく分類されたタスクおよび計算を管理するためにタスクとタスク グループを使用します。 タスク グループを入れ子にすることで、並列処理の "ツリー" を形成できます。 並列処理ツリーの図を次に示します。 この図では、tg1 と tg2 はタスク グループを表し、t1、t2、t3、t4、および t5 はタスク グループによって実行される処理を表しています。
前の図のツリーを作成するために必要なコード例を次に示します。 この例では、tg1 と tg2 が concurrency::structured_task_group オブジェクトであり、t1、t2、t3、t4、および t5 が concurrency::task_handle オブジェクトです。
// task-tree.cpp
// compile with: /c /EHsc
#include <ppl.h>
#include <sstream>
#include <iostream>
#include <sstream>
using namespace concurrency;
using namespace std;
void create_task_tree()
{
// Create a task group that serves as the root of the tree.
structured_task_group tg1;
// Create a task that contains a nested task group.
auto t1 = make_task([&] {
structured_task_group tg2;
// Create a child task.
auto t4 = make_task([&] {
// TODO: Perform work here.
});
// Create a child task.
auto t5 = make_task([&] {
// TODO: Perform work here.
});
// Run the child tasks and wait for them to finish.
tg2.run(t4);
tg2.run(t5);
tg2.wait();
});
// Create a child task.
auto t2 = make_task([&] {
// TODO: Perform work here.
});
// Create a child task.
auto t3 = make_task([&] {
// TODO: Perform work here.
});
// Run the child tasks and wait for them to finish.
tg1.run(t1);
tg1.run(t2);
tg1.run(t3);
tg1.wait();
}
また、concurrency::task_group クラスを使用して、同様の処理ツリーを作成することもできます。 concurrency::task クラスでも、処理ツリーの概念がサポートされています。 ただし、task ツリーは依存ツリーです。 task ツリーでは、将来の処理は現在の処理の後に完了します。 タスク グループ ツリーでは、内部処理は外部処理の前に完了します。 タスクとタスク グループの違いの詳細については、タスクの並列処理に関する記事を参照してください。
[トップ]
並列タスクの取り消し
並列処理を取り消すには複数の方法があります。 推奨する方法は、キャンセル トークンを使用する方法です。 また、タスク グループでは、concurrency::task_group::cancel メソッドと concurrency::structured_task_group::cancel メソッドがサポートされています。 最後の方法は、タスクの処理関数の本体で例外をスローする方法です。 どの方法を選択した場合でも、取り消し処理はすぐに実行されません。 タスクまたはタスク グループが取り消される場合、新しい処理は開始されませんが、アクティブな処理では取り消し状態をチェックし、取り消し処理に応答する必要があります。
並列タスクを取り消すその他の例については、「チュートリアル: タスクおよび XML HTTP 要求を使用した接続」、「方法: キャンセル処理を使用して並列ループを中断する」、「方法: 例外処理を使用して並列ループを中断する」を参照してください。
キャンセル トークンを使用して並列作業を取り消す
task、task_group、および structured_task_group の各クラスでは、キャンセル トークンを使用した取り消し処理をサポートしています。 PPL では、このために concurrency::cancellation_token_source クラスと concurrency::cancellation_token クラスが定義されています。 作業を取り消すためにキャンセル トークンを使用すると、ランタイムはそのトークンをサブスクライブする新しい作業を開始しません。 既にアクティブな作業では、is_canceled メンバー関数を使用してキャンセル トークンを監視し、可能な場合は停止できます。
取り消し処理を開始するには、concurrency::cancellation_token_source::cancel メソッドを呼び出します。 次の方法で取り消し処理に応答します。
taskオブジェクトの場合、concurrency::cancel_current_task 関数を使用します。cancel_current_taskが現在のタスクとすべての値ベースの継続を取り消します (タスクまたはその継続に関連付けられているキャンセル "トークン" は取り消しません)。タスク グループと並列アルゴリズムの場合、concurrency::is_current_task_group_canceling 関数を使用して取り消し処理を検出し、この関数から
trueが返されたら、できるだけ速やかにタスクの本体から制御を戻します (タスク グループからcancel_current_taskを呼び出さないでください)。
次の例では、タスク取り消し処理の最初の基本的なパターンを示しています。 タスクの本体は、ループ内の取り消し状態を適宜チェックします。
// task-basic-cancellation.cpp
// compile with: /EHsc
#include <ppltasks.h>
#include <concrt.h>
#include <iostream>
#include <sstream>
using namespace concurrency;
using namespace std;
bool do_work()
{
// Simulate work.
wcout << L"Performing work..." << endl;
wait(250);
return true;
}
int wmain()
{
cancellation_token_source cts;
auto token = cts.get_token();
wcout << L"Creating task..." << endl;
// Create a task that performs work until it is canceled.
auto t = create_task([&]
{
bool moreToDo = true;
while (moreToDo)
{
// Check for cancellation.
if (token.is_canceled())
{
// TODO: Perform any necessary cleanup here...
// Cancel the current task.
cancel_current_task();
}
else
{
// Perform work.
moreToDo = do_work();
}
}
}, token);
// Wait for one second and then cancel the task.
wait(1000);
wcout << L"Canceling task..." << endl;
cts.cancel();
// Wait for the task to cancel.
wcout << L"Waiting for task to complete..." << endl;
t.wait();
wcout << L"Done." << endl;
}
/* Sample output:
Creating task...
Performing work...
Performing work...
Performing work...
Performing work...
Canceling task...
Waiting for task to complete...
Done.
*/
cancel_current_task 関数がスローします。したがって、現在のループまたは関数から明示的に戻る必要はありません。
ヒント
cancel_current_task の代わりに、concurrency::interruption_point 関数を呼び出すこともできます。
取り消し処理に応答するときは cancel_current_task を呼び出すことが重要です。この関数によって、タスクが取り消し状態に遷移します。 cancel_current_task を呼び出さずに早期に戻った場合、操作は完了状態に遷移し、すべての値ベースの継続が実行されます。
注意事項
コードから task_canceled をスローしないでください。 代わりに cancel_current_task を呼び出してください。
タスクが取り消し状態になると、concurrency::task::get メソッドは concurrency::task_canceled をスローします (逆に、 concurrency::task::wait は task_status::canceled を返し、スローしません)。次の例は、タスクベースの継続に対するこの動作を示しています。 タスク ベースの継続は、その継続元タスクが取り消された場合でも必ず呼び出されます。
// task-canceled.cpp
// compile with: /EHsc
#include <ppltasks.h>
#include <iostream>
using namespace concurrency;
using namespace std;
int wmain()
{
auto t1 = create_task([]() -> int
{
// Cancel the task.
cancel_current_task();
});
// Create a continuation that retrieves the value from the previous.
auto t2 = t1.then([](task<int> t)
{
try
{
int n = t.get();
wcout << L"The previous task returned " << n << L'.' << endl;
}
catch (const task_canceled& e)
{
wcout << L"The previous task was canceled." << endl;
}
});
// Wait for all tasks to complete.
t2.wait();
}
/* Output:
The previous task was canceled.
*/
値ベースの継続は、明示的なトークンで作成された場合を除き、継続元タスクのトークンを継承するため、継続元タスクがまだ実行中の場合でも、すぐに取り消し状態になります。 したがって、取り消し後に継続元タスクによってスローされた例外は、継続タスクに反映されません。 取り消し処理によって、継続元タスクの状態は常にオーバーライドされます。 次の例は、前の例に似ていますが、値ベースの継続の動作を示しています。
auto t1 = create_task([]() -> int
{
// Cancel the task.
cancel_current_task();
});
// Create a continuation that retrieves the value from the previous.
auto t2 = t1.then([](int n)
{
wcout << L"The previous task returned " << n << L'.' << endl;
});
try
{
// Wait for all tasks to complete.
t2.get();
}
catch (const task_canceled& e)
{
wcout << L"The task was canceled." << endl;
}
/* Output:
The task was canceled.
*/
注意事項
task コンストラクターまたは concurrency::create_task 関数にキャンセル トークンを渡さない場合、そのタスクは取り消し可能になりません。 また、入れ子のタスク (別のタスクの本体で作成されたタスク) のコンストラクターに同じキャンセル トークンを渡して、すべてのタスクを同時に取り消す必要があります。
キャンセル トークンが取り消されるときに任意のコードを実行できます。 たとえば、ユーザーが操作を取り消すためにユーザー インターフェイスの [キャンセル] ボタンをクリックした場合、ユーザーが別の操作を開始するまでそのボタンを無効にすることができます。 次の例は、concurrency::cancellation_token::register_callback メソッドを使用して、キャンセル トークンが取り消されるときに実行されるコールバック関数を登録する方法を示しています。
// task-cancellation-callback.cpp
// compile with: /EHsc
#include <ppltasks.h>
#include <iostream>
using namespace concurrency;
using namespace std;
int wmain()
{
cancellation_token_source cts;
auto token = cts.get_token();
// An event that is set in the cancellation callback.
event e;
cancellation_token_registration cookie;
cookie = token.register_callback([&e, token, &cookie]()
{
wcout << L"In cancellation callback..." << endl;
e.set();
// Although not required, demonstrate how to unregister
// the callback.
token.deregister_callback(cookie);
});
wcout << L"Creating task..." << endl;
// Create a task that waits to be canceled.
auto t = create_task([&e]
{
e.wait();
}, token);
// Cancel the task.
wcout << L"Canceling task..." << endl;
cts.cancel();
// Wait for the task to cancel.
t.wait();
wcout << L"Done." << endl;
}
/* Sample output:
Creating task...
Canceling task...
In cancellation callback...
Done.
*/
タスクの並列処理に関するドキュメントでは、値ベースの継続とタスクベースの継続の違いについて説明しています。 継続タスクに cancellation_token オブジェクトを提供しない場合、継続はキャンセル トークンを継続元タスクから次のように継承します。
値ベースの継続は、継続元タスクのキャンセル トークンを必ず継承します。
タスク ベースの継続は、継続元タスクのキャンセル トークンを継承しません。 タスク ベースの継続を取り消し可能にする唯一の方法は、明示的にキャンセル トークンを渡すことです。
これらの動作は、違反になったタスク (つまり、例外をスローするタスク) の影響を受けません。 この場合、値ベースの継続は取り消され、タスクベースの継続は取り消されません。
注意事項
別のタスクに作成されているタスク (つまり、入れ子のタスク) は、親タスクのキャンセル トークンを継承しません。 値ベースの継続のみ、継続元タスクのキャンセル トークンを継承します。
ヒント
cancellation_token オブジェクトを受け取るコンストラクターまたは関数を呼び出し、その操作を取り消し可能にしない場合は、concurrency::cancellation_token::none メソッドを使用します。
また、task_group オブジェクトまたは structured_task_group オブジェクトのコンストラクターにキャンセル トークンを指定できます。 このとき重要な点は、子タスク グループがこのキャンセル トークンを継承することです。 parallel_for を呼び出すときに実行される concurrency::run_with_cancellation_token 関数を使用して、この概念を示している例については、このドキュメントで後述する「並列アルゴリズムの取り消し」を参照してください。
[トップ]
キャンセル トークンとタスク構成
concurrency::when_all 関数と concurrency::when_any 関数は、共通のパターンを実装するために複数のタスクを構成するときに役立ちます。 このセクションでは、キャンセル トークンを使用した場合のこれらの関数の動作について説明します。
キャンセル トークンを when_all 関数または when_any 関数に指定すると、その関数は、そのキャンセル トークンが取り消されたとき、または参加タスクの 1 つが取り消し状態になるか例外をスローしたときにのみ取り消します。
when_all 関数にキャンセル トークンを指定していない場合、この関数は、操作全体を構成する各タスクからキャンセル トークンを継承します。 when_all から返されるタスクは、これらのトークンのいずれかが取り消され、1 つ以上の参加タスクがまだ開始されていないか実行中のときに取り消されます。 同様の動作は、タスクの 1 つが例外をスローしたときに発生します。when_all から返されるタスクは、その例外によってすぐに取り消されます。
ランタイムは、タスクが完了したときに when_any 関数から返されるタスクのキャンセル トークンを選択します。 完了状態になった参加タスクがなく、1 つまたは複数のタスクが例外をスローした場合、スローしたタスクの 1 つが when_any を完了するために選択され、そのトークンが最後のタスクのトークンとして選択されます。 複数のタスクが完了状態になった場合、when_any タスクから返されるタスクは、完了状態になります。 ランタイムは、他の実行中のタスクが後で完了する可能性がある場合でも、when_any から返されるタスクがすぐに取り消されないように、完了時にトークンが取り消されていない完了したタスクを選択しようとします。
[トップ]
cancel メソッドを使用して並列作業を取り消す
concurrency::task_group::cancel メソッドと concurrency::structured_task_group::cancel メソッドは、タスク グループを取り消し状態に設定します。 cancel を呼び出すと、それ以降はタスク グループでタスクが開始されなくなります。 cancel メソッドは、複数の子タスクから呼び出すことができます。 タスクを取り消すと、concurrency::task_group::wait メソッドおよび concurrency::structured_task_group::wait メソッドで concurrency::canceled が返されるようになります。
タスク グループが取り消されると、各子タスクからのランタイムの呼び出しによって "割り込みポイント" がトリガーされる場合があります。この場合、ランタイムは内部的な例外をスローおよびキャッチして、アクティブなタスクを取り消します。 コンカレンシー ランタイムでは、特定の割り込みポイントが定義されていません。割り込みポイントは、ランタイムに対する任意の呼び出しで発生します。 ランタイムは、取り消し処理を実行するために、自身がスローした例外を処理する必要があります。 このため、タスクの本体で不明な例外を処理しないでください。
子タスクが時間のかかる処理を実行しており、ランタイムの呼び出しを行わない場合、子タスクは定期的に取り消し状態をチェックして、適切なタイミングで終了する必要があります。 処理の取り消し状態を判定する方法の 1 つを次の例に示します。 タスク t4 は、エラーの発生時に親タスク グループを取り消します。 タスク t5 は、structured_task_group::is_canceling メソッドを定期的に呼び出して、取り消し状態をチェックします。 親タスク グループが取り消されると、タスク t5 はメッセージを表示して終了します。
structured_task_group tg2;
// Create a child task.
auto t4 = make_task([&] {
// Perform work in a loop.
for (int i = 0; i < 1000; ++i)
{
// Call a function to perform work.
// If the work function fails, cancel the parent task
// and break from the loop.
bool succeeded = work(i);
if (!succeeded)
{
tg2.cancel();
break;
}
}
});
// Create a child task.
auto t5 = make_task([&] {
// Perform work in a loop.
for (int i = 0; i < 1000; ++i)
{
// To reduce overhead, occasionally check for
// cancelation.
if ((i%100) == 0)
{
if (tg2.is_canceling())
{
wcout << L"The task was canceled." << endl;
break;
}
}
// TODO: Perform work here.
}
});
// Run the child tasks and wait for them to finish.
tg2.run(t4);
tg2.run(t5);
tg2.wait();
この例では、タスク ループが 100 回繰り返されるたびに取り消し状態がチェックされます。 取り消し状態をチェックする頻度は、タスクで実行される処理の量と、取り消し処理にタスクがどの程度すばやく応答する必要があるのかによって決まります。
親タスク グループ オブジェクトにアクセスできない場合は、concurrency::is_current_task_group_canceling 関数を呼び出して、親タスク グループが取り消されたかどうかを確認します。
cancel メソッドは、子タスクにのみ影響を及ぼします。 たとえば、並列処理ツリーの図のタスク グループ tg1 を取り消すと、ツリー内のすべてのタスク (t1、t2、t3、t4、および t5) が取り消されます。 入れ子になったタスク グループ tg2 を取り消すと、タスク t4 および t5 のみ影響を受けます。
cancel メソッドを呼び出すと、子タスク グループもすべて取り消されます。 しかし、取り消し処理は、並列処理ツリーにおけるタスク グループの親には影響しません。 以降の例では、並列処理ツリーの図に基づいてこのことを示します。
最初の例では、タスク グループ t4 の子であるタスク tg2 の処理関数を作成します。 この処理関数は、関数 work をループ内で呼び出します。 work の呼び出しが失敗すると、タスクは親タスク グループを取り消します。 これにより、タスク グループ tg2 が取り消された状態になりますが、タスク グループ tg1 は取り消されません。
auto t4 = make_task([&] {
// Perform work in a loop.
for (int i = 0; i < 1000; ++i)
{
// Call a function to perform work.
// If the work function fails, cancel the parent task
// and break from the loop.
bool succeeded = work(i);
if (!succeeded)
{
tg2.cancel();
break;
}
}
});
次の例は、最初の例と似ていますが、タスクがタスク グループ tg1 を取り消す点が異なっています。 これにより、ツリー内のすべてのタスク (t1、t2、t3、t4、および t5) が影響を受けます。
auto t4 = make_task([&] {
// Perform work in a loop.
for (int i = 0; i < 1000; ++i)
{
// Call a function to perform work.
// If the work function fails, cancel all tasks in the tree.
bool succeeded = work(i);
if (!succeeded)
{
tg1.cancel();
break;
}
}
});
structured_task_group クラスはスレッドセーフではありません。 したがって、子タスクが親 structured_task_group オブジェクトのメソッドを呼び出すと、未定義の動作が実行されます。 structured_task_group::cancel メソッドと concurrency::structured_task_group::is_canceling メソッドには、この規則が適用されません。 子タスクがこれらのメソッドを呼び出すことで、親タスク グループを取り消したり、取り消し状態をチェックしたりできます。
注意事項
task オブジェクトの子として実行するタスク グループによって実行される処理を取り消すためにキャンセル トークンを使用できますが、タスク グループで実行する task_group::cancel オブジェクトを取り消すために structured_task_group::cancel メソッドまたは task メソッドは使用できません。
[トップ]
例外を使用した並列処理の取り消し
並列処理ツリーを取り消す場合は、例外処理を行うよりもキャンセル トークンと cancel メソッドを使用する方が効率的です。 キャンセル トークンと cancel メソッドは、タスクとすべての子タスクを上位から順に取り消します。 反対に、例外処理では下位から順に処理されるため、例外が上位へ移動するたびに、子タスク グループを個別に取り消す必要があります。 例外処理に関するトピックでは、同時実行ランタイムが例外を使用してエラーを通知するしくみについて説明しています。 しかし、すべての例外がエラーの発生を示す訳ではありません。 たとえば、検索アルゴリズムでは、結果の検出時に関連付けられたタスクが取り消される場合があります。 しかし、前述したように、並列処理の取り消しを行う場合、例外処理は cancel メソッドを使用するよりも効率の点で劣ります。
注意事項
必要なときにだけを並列処理を取り消すために例外を使用することをお勧めします。 キャンセル トークンとタスク グループの cancel メソッドの方が効率的で、エラーが発生する可能性も低くなります。
タスク グループに渡す処理関数の本体で例外をスローすると、ランタイムはその例外を保存して、タスク グループの終了を待機するコンテキストにその例外をマーシャリングします。 cancel メソッドの場合と同様に、ランタイムはまだ開始されていないタスクを破棄し、新しいタスクを受け付けません。
次の 3 つ目の例は、2 つ目の例と似ていますが、タスク t4 が例外をスローすることでタスク グループ tg2 を取り消している点が異なります。 この例では、try-catch ブロックを使用して、タスク グループ tg2 が子タスクの終了を待機しているときに取り消し状態をチェックします。 最初の例と同様に、これによってタスク グループ tg2 が取り消された状態になりますが、タスク グループ tg1 は取り消されません。
structured_task_group tg2;
// Create a child task.
auto t4 = make_task([&] {
// Perform work in a loop.
for (int i = 0; i < 1000; ++i)
{
// Call a function to perform work.
// If the work function fails, throw an exception to
// cancel the parent task.
bool succeeded = work(i);
if (!succeeded)
{
throw exception("The task failed");
}
}
});
// Create a child task.
auto t5 = make_task([&] {
// TODO: Perform work here.
});
// Run the child tasks.
tg2.run(t4);
tg2.run(t5);
// Wait for the tasks to finish. The runtime marshals any exception
// that occurs to the call to wait.
try
{
tg2.wait();
}
catch (const exception& e)
{
wcout << e.what() << endl;
}
次の 4 つ目の例では、例外処理を使用して処理ツリー全体を取り消します。 この例では、タスク グループ tg1 が子タスクの終了を待機しているときではなく、タスク グループ tg2 が子タスクの終了を待機しているときに、例外をキャッチします。 2 番目の例と同様に、これによってツリー内の 2 つのタスク グループ tg1 および tg2 の両方が取り消された状態になります。
// Run the child tasks.
tg1.run(t1);
tg1.run(t2);
tg1.run(t3);
// Wait for the tasks to finish. The runtime marshals any exception
// that occurs to the call to wait.
try
{
tg1.wait();
}
catch (const exception& e)
{
wcout << e.what() << endl;
}
task_group::wait メソッドと structured_task_group::wait メソッドは、子タスクが例外をスローしたときに実行されるため、これらのメソッドから戻り値を受け取ることはありません。
[トップ]
並列アルゴリズムの取り消し
PPL の並列アルゴリズム (parallel_for など) は、タスク グループを基準として構築されています。 このため、これまで説明した方法のうちの多くを使用して、並列アルゴリズムを取り消すことができます。
以降の例では、並列アルゴリズムを取り消すためのいくつかの方法を示します。
run_with_cancellation_token 関数を使用して parallel_for アルゴリズムを呼び出す例を次に示します。 run_with_cancellation_token 関数は、引数としてキャンセル トークンを受け取り、指定された処理関数を同期的に呼び出します。 並列アルゴリズムはタスクに基づいて構築されるため、親タスクのキャンセル トークンを継承します。 したがって、parallel_for は取り消し処理に応答できます。
// cancel-parallel-for.cpp
// compile with: /EHsc
#include <ppltasks.h>
#include <iostream>
#include <sstream>
using namespace concurrency;
using namespace std;
int wmain()
{
// Call parallel_for in the context of a cancellation token.
cancellation_token_source cts;
run_with_cancellation_token([&cts]()
{
// Print values to the console in parallel.
parallel_for(0, 20, [&cts](int n)
{
// For demonstration, cancel the overall operation
// when n equals 11.
if (n == 11)
{
cts.cancel();
}
// Otherwise, print the value.
else
{
wstringstream ss;
ss << n << endl;
wcout << ss.str();
}
});
}, cts.get_token());
}
/* Sample output:
15
16
17
10
0
18
5
*/
concurrency::structured_task_group::run_and_wait メソッドを使用して parallel_for アルゴリズムを呼び出す例を次に示します。 structured_task_group::run_and_wait メソッドは、指定されたタスクの終了を待機します。 structured_task_group オブジェクトによって、処理関数でタスクを取り消すことができるようになります。
// To enable cancelation, call parallel_for in a task group.
structured_task_group tg;
task_group_status status = tg.run_and_wait([&] {
parallel_for(0, 100, [&](int i) {
// Cancel the task when i is 50.
if (i == 50)
{
tg.cancel();
}
else
{
// TODO: Perform work here.
}
});
});
// Print the task group status.
wcout << L"The task group status is: ";
switch (status)
{
case not_complete:
wcout << L"not complete." << endl;
break;
case completed:
wcout << L"completed." << endl;
break;
case canceled:
wcout << L"canceled." << endl;
break;
default:
wcout << L"unknown." << endl;
break;
}
この例を実行すると、次の出力が生成されます。
The task group status is: canceled.
例外処理を使用して parallel_for ループを取り消す例を次に示します。 ランタイムは、例外を呼び出し元のコンテキストにマーシャリングします。
try
{
parallel_for(0, 100, [&](int i) {
// Throw an exception to cancel the task when i is 50.
if (i == 50)
{
throw i;
}
else
{
// TODO: Perform work here.
}
});
}
catch (int n)
{
wcout << L"Caught " << n << endl;
}
この例を実行すると、次の出力が生成されます。
Caught 50
ブール型のフラグを使用して parallel_for ループに取り消し処理を組み込む例を次に示します。 この例では、cancel メソッドや例外処理を使用して一連のタスク全体を取り消している訳ではないため、すべてのタスクが実行されます。 したがって、この方法では、取り消しメソッドを使用するよりも多くの計算オーバーヘッドが発生する場合があります。
// Create a Boolean flag to coordinate cancelation.
bool canceled = false;
parallel_for(0, 100, [&](int i) {
// For illustration, set the flag to cancel the task when i is 50.
if (i == 50)
{
canceled = true;
}
// Perform work if the task is not canceled.
if (!canceled)
{
// TODO: Perform work here.
}
});
どの取り消し方法にも、他の方法にはない利点があります。 特定のニーズに合った方法を採用してください。
[トップ]
キャンセルを使用しない場合
取り消し処理は、関連するタスク グループの各メンバーが適時に終了できる場合には適しています。 しかし、取り消し処理がアプリケーションに適さないケースもあります。 たとえば、タスクの取り消しは他の処理と連携して行われるため、個別のタスクがブロックされている場合は、一連のタスク全体を取り消すことができなくなります。 また、あるタスクがまだ開始されていないが、他の実行中のタスクのブロックを解除する場合、タスク グループが取り消されると、そのタスクは開始されません。 これにより、アプリケーションでデッドロックが発生する場合があります。 また、取り消し対象のタスクの子タスクで重要な操作 (リソースの解放など) が実行されるような状況でも、取り消し処理の使用はふさわしくありません。 親タスクを取り消すと一連のタスクがすべて取り消されるため、その操作は実行されなくなります。 この点を示す例については、「並列パターン ライブラリに関するベスト プラクティス」の「取り消し処理および例外処理がオブジェクトの破棄に及ぼす影響について」を参照してください。
[トップ]
関連トピック
| Title | 説明 |
|---|---|
| 方法: キャンセル処理を使用して並列ループを中断する | 取り消し処理を使用して並列検索アルゴリズムを実装する方法について説明します。 |
| 方法: 例外処理を使用して並列ループを中断する | task_group クラスを使用して基本的なツリー構造の検索アルゴリズムを作成する方法を示します。 |
| 例外処理 | タスク グループ、軽量タスク、および非同期エージェントによってスローされた例外をランタイムが処理するしくみ、およびアプリケーション内で例外に応答する方法を説明します。 |
| タスクの並列処理 | タスクとタスク グループの関係のほか、アプリケーションで非構造化タスクと構造化タスクを使用する方法について説明します。 |
| 並列アルゴリズム | データのコレクションに対して同時処理を実行する並列アルゴリズムについて説明します。 |
| 並列パターン ライブラリ (PPL) | 並列パターン ライブラリの概要を説明します。 |
リファレンス
フィードバック
以下は間もなく提供いたします。2024 年を通じて、コンテンツのフィードバック メカニズムとして GitHub の issue を段階的に廃止し、新しいフィードバック システムに置き換えます。 詳細については、「https://aka.ms/ContentUserFeedback」を参照してください。
フィードバックの送信と表示