Parallel.ForEachAsync Метод
Определение
Важно!
Некоторые сведения относятся к предварительной версии продукта, в которую до выпуска могут быть внесены существенные изменения. Майкрософт не предоставляет никаких гарантий, явных или подразумеваемых, относительно приведенных здесь сведений.
Перегрузки
ForEachAsync<TSource>(IAsyncEnumerable<TSource>, Func<TSource,CancellationToken,ValueTask>)
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
Выполняет операцию с for-each
, IEnumerable<T> в которой итерации могут выполняться параллельно.
public:
generic <typename TSource>
static System::Threading::Tasks::Task ^ ForEachAsync(System::Collections::Generic::IAsyncEnumerable<TSource> ^ source, Func<TSource, System::Threading::CancellationToken, System::Threading::Tasks::ValueTask> ^ body);
public static System.Threading.Tasks.Task ForEachAsync<TSource> (System.Collections.Generic.IAsyncEnumerable<TSource> source, Func<TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask> body);
static member ForEachAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * Func<'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask> -> System.Threading.Tasks.Task
Public Shared Function ForEachAsync(Of TSource) (source As IAsyncEnumerable(Of TSource), body As Func(Of TSource, CancellationToken, ValueTask)) As Task
Параметры типа
- TSource
Тип данных в источнике.
Параметры
- source
- IAsyncEnumerable<TSource>
Перечислимый источник данных.
- body
- Func<TSource,CancellationToken,ValueTask>
Асинхронный делегат, который вызывается один раз для каждого элемента в источнике данных.
Возвращаемое значение
Задача, представляющая всю for-each
операцию.
Исключения
Параметр source
или body
имеет значение null
.
Комментарии
Операция будет выполняться не более чем ProcessorCount параллельно.
Применяется к
ForEachAsync<TSource>(IEnumerable<TSource>, Func<TSource,CancellationToken,ValueTask>)
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
Выполняет операцию с for-each
, IEnumerable<T> в которой итерации могут выполняться параллельно.
public:
generic <typename TSource>
static System::Threading::Tasks::Task ^ ForEachAsync(System::Collections::Generic::IEnumerable<TSource> ^ source, Func<TSource, System::Threading::CancellationToken, System::Threading::Tasks::ValueTask> ^ body);
public static System.Threading.Tasks.Task ForEachAsync<TSource> (System.Collections.Generic.IEnumerable<TSource> source, Func<TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask> body);
static member ForEachAsync : seq<'Source> * Func<'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask> -> System.Threading.Tasks.Task
Public Shared Function ForEachAsync(Of TSource) (source As IEnumerable(Of TSource), body As Func(Of TSource, CancellationToken, ValueTask)) As Task
Параметры типа
- TSource
Тип данных в источнике.
Параметры
- source
- IEnumerable<TSource>
Перечислимый источник данных.
- body
- Func<TSource,CancellationToken,ValueTask>
Асинхронный делегат, который вызывается один раз для каждого элемента в источнике данных.
Возвращаемое значение
Задача, представляющая всю for-each
операцию.
Исключения
Параметр source
или body
имеет значение null
.
Комментарии
Операция будет выполняться не более чем ProcessorCount параллельно.
Применяется к
ForEachAsync<TSource>(IAsyncEnumerable<TSource>, CancellationToken, Func<TSource,CancellationToken,ValueTask>)
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
Выполняет операцию с for-each
, IEnumerable<T> в которой итерации могут выполняться параллельно.
public:
generic <typename TSource>
static System::Threading::Tasks::Task ^ ForEachAsync(System::Collections::Generic::IAsyncEnumerable<TSource> ^ source, System::Threading::CancellationToken cancellationToken, Func<TSource, System::Threading::CancellationToken, System::Threading::Tasks::ValueTask> ^ body);
public static System.Threading.Tasks.Task ForEachAsync<TSource> (System.Collections.Generic.IAsyncEnumerable<TSource> source, System.Threading.CancellationToken cancellationToken, Func<TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask> body);
static member ForEachAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * System.Threading.CancellationToken * Func<'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask> -> System.Threading.Tasks.Task
Public Shared Function ForEachAsync(Of TSource) (source As IAsyncEnumerable(Of TSource), cancellationToken As CancellationToken, body As Func(Of TSource, CancellationToken, ValueTask)) As Task
Параметры типа
- TSource
Тип данных в источнике.
Параметры
- source
- IAsyncEnumerable<TSource>
Перечислимый источник данных.
- cancellationToken
- CancellationToken
Маркер отмены, который может использоваться для отмены for-each
операции.
- body
- Func<TSource,CancellationToken,ValueTask>
Асинхронный делегат, который вызывается один раз для каждого элемента в источнике данных.
Возвращаемое значение
Задача, представляющая всю for-each
операцию.
Исключения
Параметр source
или body
имеет значение null
.
Маркер отмены был отменен. Это исключение сохраняется в возвращаемой задаче.
Комментарии
Операция будет выполняться не более чем ProcessorCount параллельно.
Применяется к
ForEachAsync<TSource>(IAsyncEnumerable<TSource>, ParallelOptions, Func<TSource,CancellationToken,ValueTask>)
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
Выполняет операцию с for-each
, IEnumerable<T> в которой итерации могут выполняться параллельно.
public:
generic <typename TSource>
static System::Threading::Tasks::Task ^ ForEachAsync(System::Collections::Generic::IAsyncEnumerable<TSource> ^ source, System::Threading::Tasks::ParallelOptions ^ parallelOptions, Func<TSource, System::Threading::CancellationToken, System::Threading::Tasks::ValueTask> ^ body);
public static System.Threading.Tasks.Task ForEachAsync<TSource> (System.Collections.Generic.IAsyncEnumerable<TSource> source, System.Threading.Tasks.ParallelOptions parallelOptions, Func<TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask> body);
static member ForEachAsync : System.Collections.Generic.IAsyncEnumerable<'Source> * System.Threading.Tasks.ParallelOptions * Func<'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask> -> System.Threading.Tasks.Task
Public Shared Function ForEachAsync(Of TSource) (source As IAsyncEnumerable(Of TSource), parallelOptions As ParallelOptions, body As Func(Of TSource, CancellationToken, ValueTask)) As Task
Параметры типа
- TSource
Тип данных в источнике.
Параметры
- source
- IAsyncEnumerable<TSource>
Перечислимый источник данных.
- parallelOptions
- ParallelOptions
Объект, используемый для настройки поведения этой операции.
- body
- Func<TSource,CancellationToken,ValueTask>
Асинхронный делегат, который вызывается один раз для каждого элемента в источнике данных.
Возвращаемое значение
Задача, представляющая всю for-each
операцию.
Исключения
Параметр source
или body
имеет значение null
.
Применяется к
ForEachAsync<TSource>(IEnumerable<TSource>, CancellationToken, Func<TSource,CancellationToken,ValueTask>)
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
Выполняет операцию с for-each
, IEnumerable<T> в которой итерации могут выполняться параллельно.
public:
generic <typename TSource>
static System::Threading::Tasks::Task ^ ForEachAsync(System::Collections::Generic::IEnumerable<TSource> ^ source, System::Threading::CancellationToken cancellationToken, Func<TSource, System::Threading::CancellationToken, System::Threading::Tasks::ValueTask> ^ body);
public static System.Threading.Tasks.Task ForEachAsync<TSource> (System.Collections.Generic.IEnumerable<TSource> source, System.Threading.CancellationToken cancellationToken, Func<TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask> body);
static member ForEachAsync : seq<'Source> * System.Threading.CancellationToken * Func<'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask> -> System.Threading.Tasks.Task
Public Shared Function ForEachAsync(Of TSource) (source As IEnumerable(Of TSource), cancellationToken As CancellationToken, body As Func(Of TSource, CancellationToken, ValueTask)) As Task
Параметры типа
- TSource
Тип данных в источнике.
Параметры
- source
- IEnumerable<TSource>
Перечислимый источник данных.
- cancellationToken
- CancellationToken
Маркер отмены, который может использоваться для отмены for-each
операции.
- body
- Func<TSource,CancellationToken,ValueTask>
Асинхронный делегат, который вызывается один раз для каждого элемента в источнике данных.
Возвращаемое значение
Задача, представляющая всю for-each
операцию.
Исключения
Параметр source
или body
имеет значение null
.
Маркер отмены был отменен. Это исключение сохраняется в возвращаемой задаче.
Комментарии
Операция будет выполняться не более чем ProcessorCount параллельно.
Применяется к
ForEachAsync<TSource>(IEnumerable<TSource>, ParallelOptions, Func<TSource,CancellationToken,ValueTask>)
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
- Исходный код:
- Parallel.ForEachAsync.cs
Выполняет операцию с for-each
, IEnumerable<T> в которой итерации могут выполняться параллельно.
public:
generic <typename TSource>
static System::Threading::Tasks::Task ^ ForEachAsync(System::Collections::Generic::IEnumerable<TSource> ^ source, System::Threading::Tasks::ParallelOptions ^ parallelOptions, Func<TSource, System::Threading::CancellationToken, System::Threading::Tasks::ValueTask> ^ body);
public static System.Threading.Tasks.Task ForEachAsync<TSource> (System.Collections.Generic.IEnumerable<TSource> source, System.Threading.Tasks.ParallelOptions parallelOptions, Func<TSource,System.Threading.CancellationToken,System.Threading.Tasks.ValueTask> body);
static member ForEachAsync : seq<'Source> * System.Threading.Tasks.ParallelOptions * Func<'Source, System.Threading.CancellationToken, System.Threading.Tasks.ValueTask> -> System.Threading.Tasks.Task
Public Shared Function ForEachAsync(Of TSource) (source As IEnumerable(Of TSource), parallelOptions As ParallelOptions, body As Func(Of TSource, CancellationToken, ValueTask)) As Task
Параметры типа
- TSource
Тип данных в источнике.
Параметры
- source
- IEnumerable<TSource>
Перечислимый источник данных.
- parallelOptions
- ParallelOptions
Объект, используемый для настройки поведения этой операции.
- body
- Func<TSource,CancellationToken,ValueTask>
Асинхронный делегат, который вызывается один раз для каждого элемента в источнике данных.
Возвращаемое значение
Задача, представляющая всю for-each
операцию.
Исключения
Параметр source
или body
имеет значение null
.