DataflowBlock 類別

定義

命名空間:

System.Threading.Tasks.Dataflow

組件:

System.Threading.Tasks.Dataflow.dll

提供一組 static (Visual Basic 中是 Shared) 方法，以處理資料流程區塊。

public ref class DataflowBlock abstract sealed

public static class DataflowBlock

type DataflowBlock = class

Public Module DataflowBlock

繼承

Object

DataflowBlock

備註

注意

TPL 資料流程程式庫 (System.Threading.Tasks.Dataflow 命名空間) 並未隨 .NET 散發。 若要在 Visual Studio 中安裝 System.Threading.Tasks.Dataflow 命名空間，請開啟您的專案，從 [專案]**** 功能表中選擇 [管理 NuGet 套件]****，並於線上搜尋 System.Threading.Tasks.Dataflow 套件。 除此之外也可使用 .Net Core CLI (執行 dotnet add package System.Threading.Tasks.Dataflow) 加以安裝。

方法

AsObservable<TOutput>(ISourceBlock<TOutput>)	建立在 IObservable<T> 之上的新 ISourceBlock<TOutput> Abstraction。
AsObserver<TInput>(ITargetBlock<TInput>)	建立在 ITargetBlock<TInput> 之上的新 IObserver<T> Abstraction。
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> 接收項目。