C# 4.0 полное руководство - 2011

гдеsourceобозначает коллекцию данных, обрабатываемых в цикле, abody —метод, который будет выполняться на каждом шаге цикла. Как пояснялось ранее в этой книге, во всех массивах, коллекциях (описываемых в главе 25) и других источниках данных поддерживается интерфейсIEnumerable.Метод, передаваемый через параметрbody,принимает в качестве своего аргумента значение или ссылку на каждый обрабатываемый в цикле элемент массива, но не его индекс. А в итоге возвращаются сведения

о состоянии цикла.

Аналогично методуFor , параллельное выполнение цикла методомForEach можно остановить, вызвав методBreak для экземпляра объекта типаParallelLoopState,передаваемого через параметрbody,при условии, что используется приведенная ниже форма методаFor Each .

public static ParallelLoopResult

ForEach(IEnumerablesource,

ActiorKTSource, ParallelLoopState>body)

В приведенном ниже примере программы демонстрируется применение методаFor Each на практике. Как и прежде, в данном примере создается крупный массив целых значений. А отличается данный пример от предыдущих тем, что метод, выполняющийся на каждом шаге цикла, просто выводит на консоль значения из массива. Как правило, методWriteLine в распараллеливаемом цикле не применяется, потому что ввод-вывод на консоль осуществляется настолько медленно, что цикл оказывается полностью привязанным к вводу-выводу. Но в данном примере методWriteLine применяется исключительно в целях демонстрации возможностей методаForEach .При обнаружении отрицательного значения выполнение цикла прерывается вызовом методаBreak. Несмотря на то что методBreak вызывается в одной задаче,другаязадача может по-прежнему выполняться в течение нескольких шагов цикла, прежде чем он будет прерван, хотя это зависит от конкретных условий работы среды выполнения.

// Использовать объекты типа ParallelLoopResult и ParallelLoopState, а также // метод Break вместе с методом ForEachO для параллельного выполнения цикла.

using System;

using System.Threading.Tasks;

class DemoParallelForWithLoopResult { static int[] data;

// Метод, служащий в качестве тела параллельно выполняемого цикла.

// В данном примере переменной v передается значение элемента массива // данных, а не индекс этого элемента.

static void DisplayData(int v, ParallelLoopState pis) {

// Прервать цикл при обнаружении отрицательного значения, if (v < 0) pls.Break;

Console.WriteLine("Значение: " + v);

static void Main {

Console.WriteLine("Основной поток запущен."); data = new int[100000000];

// Инициализировать данные.