BatchedJoinBlock<T1,T2>.ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage 方法

定义

命名空间:

System.Threading.Tasks.Dataflow

程序集:

System.Threading.Tasks.Dataflow.dll

将 DataflowMessageHeader 标识的消息的所有权从此 ISourceBlock<TOutput> 实例传递到 ITargetBlock<TInput>。

 virtual Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^ System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage(System::Threading::Tasks::Dataflow::DataflowMessageHeader messageHeader, System::Threading::Tasks::Dataflow::ITargetBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^> ^ target, [Runtime::InteropServices::Out] bool % messageConsumed) = System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^>::ConsumeMessage;

Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>> ISourceBlock<Tuple<IList<T1>,IList<T2>>>.ConsumeMessage (System.Threading.Tasks.Dataflow.DataflowMessageHeader messageHeader, System.Threading.Tasks.Dataflow.ITargetBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>> target, out bool messageConsumed);

abstract member System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * System.Threading.Tasks.Dataflow.ITargetBlock<System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>> * bool -> System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>
override this.System.Threading.Tasks.Dataflow.ISourceBlock<System.Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>.ConsumeMessage : System.Threading.Tasks.Dataflow.DataflowMessageHeader * System.Threading.Tasks.Dataflow.ITargetBlock<System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>> * bool -> System.Collections.Generic.IList<'T1> * System.Collections.Generic.IList<'T2>

Function ConsumeMessage (messageHeader As DataflowMessageHeader, target As ITargetBlock(Of Tuple(Of IList(Of T1), IList(Of T2))), ByRef messageConsumed As Boolean) As Tuple(Of IList(Of T1), IList(Of T2)) Implements ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2))).ConsumeMessage

参数

messageHeader

DataflowMessageHeader

要使用的消息的 DataflowMessageHeader。

target

ITargetBlock<Tuple<IList<T1>,IList<T2>>>

要为其使用消息的 ITargetBlock<TInput>。

messageConsumed

Boolean

如果成功使用消息，则为 true。 否则为 false。

返回

Tuple<IList<T1>,IList<T2>>

所使用的消息的值。 这可能对应于一个 DataflowMessageHeader 实例，该实例不同于之前保留并作为 messageHeader 传递给此方法的实例。 使用的 ITargetBlock<TInput> 必须使用返回值而不是作为 messageValue 传递到 OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean) 的值。 如果所请求的消息不可用，则返回值将是 null（在 Visual Basic 中为 Nothing）。

实现

ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)

例外

ArgumentException

messageHeader 无效。

ArgumentNullException

target 为 null（在 Visual Basic 中为 Nothing）。

注解

ITargetBlock<TInput>要使用此消息的实例无需链接ISourceBlock<TOutput>。 此外，此 ISourceBlock<TOutput> 实例可能从未直接向该 ITargetBlock<TInput>实例提供消息。