Gewusst wie: Verwenden eines Abbruchs zum Verlassen einer Parallel-Schleife
Dieses Beispiel zeigt, wie Abbrüche verwendet, um einen einfachen Algorithmus paralleler Suchalgorithmus implementiert wird.
Beispiel
Das folgende Beispiel verwendet das Abbrechen, um in einem Array nach einem Element zu suchen. Die Funktion parallel_find_any wird der Algorithmus concurrency::parallel_for und die concurrency::run_with_cancellation_token-Funktion, die die Position zu suchen, die den angegebenen Wert enthält. Wenn von der parallelen Schleife den Wert ermittelt, ruft sie die concurrency::cancellation_token_source::cancel-Methode auf, um die weitere Verarbeitung abzubrechen.
// 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.
*/
Der concurrency::parallel_for - Algorithmus handelt gleichzeitig. Daher führt er die Operationen nicht in einer vorgegebenen Reihenfolge aus. Wenn das Array mehrere Instanzen des Werts enthält, kann das Ergebnis eine beliebige seiner Positionen sein.
Kompilieren des Codes
Kopieren Sie den Beispielcode und fügen Sie ihn in ein Visual Studio-Projekt ein, oder fügen Sie ihn in eine Datei mit dem Namen parallel-array-search.cpp ein, und dann folgenden Befehl in einem Visual Studio-Eingabeaufforderung ausgeführt.
cl.exe /EHsc parallel-array-search.cpp
Siehe auch
Referenz
cancellation_token_source-Klasse