BroadcastBlock<T> 類別

  • 參考

定義

命名空間:
System.Threading.Tasks.Dataflow
組件:
System.Threading.Tasks.Dataflow.dll
套件:
System.Threading.Tasks.Dataflow v9.0.0-preview.3.24172.9
來源:
BroadcastBlock.cs
來源:
BroadcastBlock.cs
來源:
BroadcastBlock.cs

提供緩衝區，一次至多儲存一個項目，並在下一個訊息到達時覆寫每個訊息。

generic <typename T>
public ref class BroadcastBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, T>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<T>, System::Threading::Tasks::Dataflow::ISourceBlock<T>, System::Threading::Tasks::Dataflow::ITargetBlock<T>
public sealed class BroadcastBlock<T> : System.Threading.Tasks.Dataflow.IPropagatorBlock<T,T>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<T>, System.Threading.Tasks.Dataflow.ISourceBlock<T>, System.Threading.Tasks.Dataflow.ITargetBlock<T>
type BroadcastBlock<'T> = class
    interface IPropagatorBlock<'T, 'T>
    interface ITargetBlock<'T>
    interface IDataflowBlock
    interface ISourceBlock<'T>
    interface IReceivableSourceBlock<'T>
type BroadcastBlock<'T> = class
    interface IDataflowBlock
    interface IPropagatorBlock<'T, 'T>
    interface ISourceBlock<'T>
    interface ITargetBlock<'T>
    interface IReceivableSourceBlock<'T>
Public NotInheritable Class BroadcastBlock(Of T)
Implements IPropagatorBlock(Of T, T), IReceivableSourceBlock(Of T), ISourceBlock(Of T), ITargetBlock(Of T)

類型參數

T

指定此資料流區塊目標區塊緩衝之資料的型別。

繼承
Object
BroadcastBlock<T>
實作
IDataflowBlock IPropagatorBlock<T,T> IReceivableSourceBlock<T> ISourceBlock<T> ISourceBlock<TOutput> ITargetBlock<T> ITargetBlock<TInput>

備註

注意

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) 加以安裝。

BroadcastBlock<T> 一次公開最多一個專案。 不過，與 不同的 WriteOnceBlock<T> 是，當新元素提供給 區塊時，該元素將會被覆寫。 BroadcastBlock<T> 確保目前的專案會在允許覆寫專案之前，廣播至任何連結的目標。

建構函式

BroadcastBlock<T>(Func<T,T>)

使用指定的複製函式初始化 BroadcastBlock<T>。
BroadcastBlock<T>(Func<T,T>, DataflowBlockOptions)

BroadcastBlock<T>使用指定的複製函式和 DataflowBlockOptions ，初始化 。

屬性

Completion

取得 Task，其表示非同步作業和資料流程區塊的完成。

方法

Complete()

向 IDataflowBlock 發出訊號，表示不應接受也不應產生任何其他訊息，也不應使用任何其他延後的訊息。
Equals(Object)

判斷指定的物件是否等於目前的物件。

(繼承來源 Object)
GetHashCode()

做為預設雜湊函式。

(繼承來源 Object)
GetType()

取得目前執行個體的 Type。

(繼承來源 Object)
LinkTo(ITargetBlock<T>, DataflowLinkOptions)

ISourceBlock<TOutput>將 連結到指定的 ITargetBlock<TInput> 。
MemberwiseClone()

建立目前 Object 的淺層複製。

(繼承來源 Object)
ToString()

傳回表示這個 IDataflowBlock 執行個體之格式化名稱的字串。
TryReceive(Predicate<T>, T)

嘗試以同步方式從 IReceivableSourceBlock<TOutput> 接收可用的輸出項目。

明確介面實作

IDataflowBlock.Fault(Exception)

造成 IDataflowBlock 在 Faulted 狀態下完成。
IReceivableSourceBlock<T>.TryReceiveAll(IList<T>)

嘗試以同步方式從 IReceivableSourceBlock<TOutput> 接收所有可用項目。
ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T>, Boolean)

由連結的ITargetBlock<TInput>呼叫以接受及使用先前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。
ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T>)

由連結的ITargetBlock<TInput>呼叫以釋出先前由此 DataflowMessageHeader 保留的 ISourceBlock<TOutput>。
ISourceBlock<T>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T>)

由連結的ITargetBlock<TInput>呼叫以保留先前由此 DataflowMessageHeader 提供的 ISourceBlock<TOutput>。
ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean)

提供了訊息給ITargetBlock<TInput>，讓目標有機會使用或延後訊息。

擴充方法

AsObservable<TOutput>(ISourceBlock<TOutput>)

建立在 IObservable<T> 之上的新 ISourceBlock<TOutput> Abstraction。
AsObserver<TInput>(ITargetBlock<TInput>)

建立在 IObserver<T> 之上的新 ITargetBlock<TInput> Abstraction。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)

ISourceBlock<TOutput>將 連結到指定的 ITargetBlock<TInput> 。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)

ISourceBlock<TOutput>使用指定的 ITargetBlock<TInput> 篩選，將 連結到指定的 。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)

ISourceBlock<TOutput>使用指定的 ITargetBlock<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> 接收項目。

適用於