방법: 취소를 사용하여 병렬 루프 중단
취소를 사용 하 여 기본 병렬 검색 알고리즘을 구현 하는 방법을 보여 주는이 예제입니다.
예제
다음 예제에서는 취소를 사용하여 배열에서 요소를 검색합니다.parallel_find_any 함수를 사용 하는 concurrency::parallel_for 알고리즘 및 concurrency::run_with_cancellation_token 함수를 지정 된 값이 있는 위치를 찾으려면.병렬 루프 값을 찾으면 호출을 concurrency::cancellation_token_source::cancel 이후의 작업을 취소 하는 방법.
// parallel-array-search.cpp
// compile with: /EHsc
#include <ppl.h>
#include <iostream>
#include <random>
using namespace concurrency;
using namespace std;
// Returns the position in the provided array that contains the given value,
// or -1 if the value is not in the array.
template<typename T>
int parallel_find_any(const T a[], size_t count, const T& what)
{
// The position of the element in the array.
// The default value, -1, indicates that the element is not in the array.
int position = -1;
// Call parallel_for in the context of a cancellation token to search for the element.
cancellation_token_source cts;
run_with_cancellation_token([count, what, &a, &position, &cts]()
{
parallel_for(std::size_t(0), count, [what, &a, &position, &cts](int n) {
if (a[n] == what)
{
// Set the return value and cancel the remaining tasks.
position = n;
cts.cancel();
}
});
}, cts.get_token());
return position;
}
int wmain()
{
const size_t count = 10000;
int values[count];
// Fill the array with random values.
mt19937 gen(34);
for (size_t i = 0; i < count; ++i)
{
values[i] = gen()%10000;
}
// Search for any position in the array that contains value 3123.
const int what = 3123;
int position = parallel_find_any(values, count, what);
if (position >= 0)
{
wcout << what << L" is at position " << position << L'.' << endl;
}
else
{
wcout << what << L" is not in the array." << endl;
}
}
/* Sample output:
3123 is at position 7835.
*/
Concurrency::parallel_for 알고리즘 역할을 동시에 합니다.따라서 미리 결정된 순서대로 작업을 수행하지 않습니다.지정된 값의 인스턴스가 배열에 여러 개 포함되어 있으면 결과는 해당 위치 중 하나가 될 수 있습니다.
코드 컴파일
예제 코드를 복사 하 고 Visual Studio 프로젝트에 붙여 또는 라는 파일에 붙여 병렬-배열-search.cpp 및 다음 Visual Studio 명령 프롬프트 창에서 다음 명령을 실행 합니다.
cl.exe /EHsc parallel-array-search.cpp