DataflowBlock Класс

Определение

Пространство имен:

System.Threading.Tasks.Dataflow

Сборка:

System.Threading.Tasks.Dataflow.dll

Предоставляет набор статических методов (Shared в Visual Basic) для работы с блоками потоков данных.

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

Наследование

Object

DataflowBlock

Комментарии

Примечание

Библиотека потоков данных TPL (пространство имен System.Threading.Tasks.Dataflow) не поставляется с .NET. Чтобы установить пространство имен System.Threading.Tasks.Dataflow в Visual Studio, откройте проект, выберите Управление пакетами NuGet в меню Проект и выполните поиск пакета System.Threading.Tasks.Dataflow в Интернете. Вы также можете установить его, выполнив в .NET Core CLI команду dotnet add package System.Threading.Tasks.Dataflow.

Методы

AsObservable<TOutput>(ISourceBlock<TOutput>)	Создает новую абстракцию IObservable<T> для ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)	Создает новую абстракцию IObserver<T> для ITargetBlock<TInput>.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>)	Отслеживает три источника потоков данных, вызывая предоставленный обработчик для источника, который первым сделает данные доступными.
Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions)	Отслеживает три источника потоков данных, вызывая предоставленный обработчик для источника, который первым сделает данные доступными.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>)	Отслеживает два источника потоков данных, вызывая предоставленный обработчик для источника, который первым сделает данные доступными.
Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions)	Отслеживает два источника потоков данных, вызывая предоставленный обработчик для источника, который первым сделает данные доступными.
Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>)	Инкапсулирует целевой объект и источник в один блок распространения.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Связывает ISourceBlock<TOutput> с указанным ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Связывает ISourceBlock<TOutput> с указанным ITargetBlock<TInput>, используя указанный фильтр.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Связывает ISourceBlock<TOutput> с указанным ITargetBlock<TInput>, используя указанный фильтр.
NullTarget<TInput>()	Получает целевой блок, который синхронно принимает все сообщения, предлагаемые на него, и удаляет их.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Предоставляет Task<TResult>, которое асинхронным образом выполняет мониторинг источника доступного вывода.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Предоставляет Task<TResult>, которое асинхронным образом выполняет мониторинг источника доступного вывода.
Post<TInput>(ITargetBlock<TInput>, TInput)	Отправляет элемент в объект ITargetBlock<TInput>.
Receive<TOutput>(ISourceBlock<TOutput>)	Синхронно получает значение от указанного источника.
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Синхронно получает значение из указанного источника и предоставляет токен для отмены операции.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Синхронно получает значение из указанного источника, отслеживание необязательно точкой времени ожидания.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Синхронно получает значение из указанного источника, обеспечивая токен для отмены операции за необязательным и интервал времени ожидания.
ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken)	Создает объект IAsyncEnumerable<T> , позволяющий получать все данные из источника.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	Асинхронно получает значение от указанного источника.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Асинхронно получает значение из указанного источника и предоставляет токен для отмены операции.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Асинхронно получает значение из указанного источника, отслеживание необязательно точкой времени ожидания.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Асинхронно получает значение из указанного источника, обеспечивая токен для отмены операции за необязательным и интервал времени ожидания.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Асинхронно предлагает сообщение в целевому блоку сообщений, позволяет задержки.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Асинхронно предлагает сообщение в целевому блоку сообщений, позволяет задержки.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Пытается синхронно получить элемент из ISourceBlock<TOutput>.