TransformBlock<TInput,TOutput> 类

定义

命名空间:: System.Threading.Tasks.Dataflow

程序集:: System.Threading.Tasks.Dataflow.dll

重要

一些信息与预发行产品相关，相应产品在发行之前可能会进行重大修改。对于此处提供的信息，Microsoft 不作任何明示或暗示的担保。

提供一个数据流块，该块为收到的每个数据元素调用提供的 Func<T,TResult> 委托。

generic <typename TInput, typename TOutput>
public ref class TransformBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<TInput, TOutput>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ISourceBlock<TOutput>, System::Threading::Tasks::Dataflow::ITargetBlock<TInput>

public sealed class TransformBlock<TInput,TOutput> : System.Threading.Tasks.Dataflow.IPropagatorBlock<TInput,TOutput>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ISourceBlock<TOutput>, System.Threading.Tasks.Dataflow.ITargetBlock<TInput>

type TransformBlock<'Input, 'Output> = class
    interface IPropagatorBlock<'Input, 'Output>
    interface ITargetBlock<'Input>
    interface IDataflowBlock
    interface ISourceBlock<'Output>
    interface IReceivableSourceBlock<'Output>

Public NotInheritable Class TransformBlock(Of TInput, TOutput)
Implements IPropagatorBlock(Of TInput, TOutput), IReceivableSourceBlock(Of TOutput), ISourceBlock(Of TOutput), ITargetBlock(Of TInput)

类型参数

TInput

指定由此 TransformBlock<TInput,TOutput>接收和操作的数据的类型。

TOutput

指定由此 TransformBlock<TInput,TOutput>输出的数据的类型。

继承: Object
TransformBlock<TInput,TOutput>

实现: IDataflowBlock IPropagatorBlock<TInput,TOutput> IReceivableSourceBlock<TOutput> ISourceBlock<TOutput> 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。

构造函数

名称	说明
TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>, ExecutionDataflowBlockOptions)	用 TransformBlock<TInput,TOutput> 指定的 Func<T,TResult> 和 ExecutionDataflowBlockOptions。
TransformBlock<TInput,TOutput>(Func<TInput,Task<TOutput>>)	用指定的TransformBlock<TInput,TOutput>值初始化新Func<T,TResult>项。
TransformBlock<TInput,TOutput>(Func<TInput,TOutput>, ExecutionDataflowBlockOptions)	用 TransformBlock<TInput,TOutput> 指定的 Func<T,TResult> 和 ExecutionDataflowBlockOptions。
TransformBlock<TInput,TOutput>(Func<TInput,TOutput>)	用指定的TransformBlock<TInput,TOutput>值初始化新Func<T,TResult>项。

属性

名称	说明
Completion	获取一个 Task 表示数据流块的异步操作和完成。
InputCount	获取等待此块处理的输入项数。
OutputCount	获取可从此块接收的输出项数。

方法

名称	说明
Complete()	信号 IDataflowBlock 表明，它不应接受或生成更多消息，也不应再使用任何推迟的消息。
Equals(Object)	确定指定的对象是否等于当前对象。 (继承自 Object)
GetHashCode()	用作默认哈希函数。 (继承自 Object)
GetType()	获取当前实例的 Type。 (继承自 Object)
LinkTo(ITargetBlock<TOutput>, DataflowLinkOptions)	链接到 ISourceBlock<TOutput> 指定的 ITargetBlock<TInput> 。
MemberwiseClone()	创建当前 Object的浅表副本。 (继承自 Object)
ToString()	返回一个字符串，表示此 IDataflowBlock 实例的格式名称。
TryReceive(Predicate<TOutput>, TOutput)	尝试从 <a0/> 同步接收可用输出项。
TryReceiveAll(IList<TOutput>)	尝试从 <a0/> 同步接收所有可用项。

显式接口实现

名称	说明
IDataflowBlock.Fault(Exception)	使状态 IDataflowBlock 完成 Faulted 。
ISourceBlock<TOutput>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<TOutput>, Boolean)	由链接 ITargetBlock<TInput> 调用以接受和使用 DataflowMessageHeader 以前由此 ISourceBlock<TOutput>提供的。
ISourceBlock<TOutput>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<TOutput>)	由链接 ITargetBlock<TInput> 调用，以释放以前 DataflowMessageHeader 保留的此 ISourceBlock<TOutput>版本。
ISourceBlock<TOutput>.ReserveMessage(DataflowMessageHeader, ITargetBlock<TOutput>)	由链接 ITargetBlock<TInput> 调用，以保留以前提供 DataflowMessageHeader 的方法 ISourceBlock<TOutput>。
ITargetBlock<TInput>.OfferMessage(DataflowMessageHeader, TInput, ISourceBlock<TInput>, Boolean)	向消息提供一条消息 ITargetBlock<TInput>，使目标有机会使用或推迟消息。

扩展方法

名称	说明
AsObservable<TOutput>(ISourceBlock<TOutput>)	创建一个新的IObservable<T>抽象。ISourceBlock<TOutput>
AsObserver<TInput>(ITargetBlock<TInput>)	创建一个新的IObserver<T>抽象。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>。
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	链接到 ISourceBlock<TOutput> 指定的 ITargetBlock<TInput>。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	提供一个 Task<TResult> 异步监视可用输出的源。
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	提供一个 Task<TResult> 异步监视可用输出的源。
Post<TInput>(ITargetBlock<TInput>, TInput)	将项目发布到 .ITargetBlock<TInput>
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	同步接收来自指定源的值，并提供用于取消操作的令牌。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	从指定源同步接收值，提供一个令牌来取消操作并观察可选的超时间隔。
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	同步接收来自指定源的值，观察可选的超时期限。
Receive<TOutput>(ISourceBlock<TOutput>)	从指定的源同步接收值。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	从指定源异步接收值，并提供用于取消操作的令牌。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	从指定源异步接收值，提供一个令牌来取消操作并观察可选的超时间隔。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	从指定源异步接收值，观察可选的超时期限。
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	从指定源异步接收值。
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	以异步方式向目标消息块提供消息，从而允许推迟。
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	以异步方式向目标消息块提供消息，从而允许推迟。
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	尝试从 . ISourceBlock<TOutput>中同步接收项。

适用于

反馈

此页面是否有帮助？