BatchBlock<T> 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
提供将输入批处理到数组中的数据流块。
generic <typename T>
public ref class BatchBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, cli::array <T> ^>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ITargetBlock<T>
public sealed class BatchBlock<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 BatchBlock<'T> = class
interface IPropagatorBlock<'T, 'T[]>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T[]>
interface IReceivableSourceBlock<'T[]>
type BatchBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T[]>
interface ISourceBlock<'T[]>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T[]>
Public NotInheritable Class BatchBlock(Of T)
Implements IPropagatorBlock(Of T, T()), IReceivableSourceBlock(Of T()), ISourceBlock(Of T()), ITargetBlock(Of T)
类型参数
- T
指定数据的类型将放置于多个批。
- 继承
-
BatchBlock<T>
- 实现
注解
备注
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
。
构造函数
BatchBlock<T>(Int32) |
初始化指定批次大小的新 BatchBlock<T>。 |
BatchBlock<T>(Int32, GroupingDataflowBlockOptions) |
用指定的批大小、定义选项和块选项初始化新的 BatchBlock<T>。 |
属性
BatchSize |
获取由此 BatchBlock<T> 生成的批的大小。 |
Completion |
获取 Task,其表示数据流块的操作和完成。 |
OutputCount |
获取可从此块中接收的输出项的数量。 |
方法
Complete() |
通知 IDataflowBlock,告知其不应该生成任何更多的消息也不应使用任何更多的延迟消息。 |
Equals(Object) |
确定指定对象是否等于当前对象。 (继承自 Object) |
GetHashCode() |
作为默认哈希函数。 (继承自 Object) |
GetType() |
获取当前实例的 Type。 (继承自 Object) |
LinkTo(ITargetBlock<T[]>, DataflowLinkOptions) |
将 ISourceBlock<TOutput> 链接到指定的 ITargetBlock<TInput>。 |
MemberwiseClone() |
创建当前 Object 的浅表副本。 (继承自 Object) |
ToString() |
返回一个字符串,该字符串表示此 IDataflowBlock 实例的格式化名称。 |
TriggerBatch() |
触发 BatchBlock<T> 以启动批处理操作,即使当前排队或推迟项的数量小于 BatchSize。 |
TryReceive(Predicate<T[]>, T[]) |
从 IReceivableSourceBlock<TOutput> 中尝试同步接收可用输出项。 |
TryReceiveAll(IList<T[]>) |
从 IReceivableSourceBlock<TOutput> 中尝试同步接收所有可用项。 |