JoinBlock<T1,T2> 类
定义
重要
一些信息与预发行产品相关,相应产品在发行之前可能会进行重大修改。 对于此处提供的信息,Microsoft 不作任何明示或暗示的担保。
提供一个数据流块,该数据流块跨多个数据流源(不一定是同一类型)联接,等待一个项到达每个类型,然后才能作为每个类型的一个项一起释放为元组。
generic <typename T1, typename T2>
public ref class JoinBlock sealed : System::Threading::Tasks::Dataflow::IReceivableSourceBlock<Tuple<T1, T2> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<T1, T2> ^>
public sealed class JoinBlock<T1,T2> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<T1,T2>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<T1,T2>>
type JoinBlock<'T1, 'T2> = class
interface IReceivableSourceBlock<'T1 * 'T2>
interface ISourceBlock<'T1 * 'T2>
interface IDataflowBlock
Public NotInheritable Class JoinBlock(Of T1, T2)
Implements IReceivableSourceBlock(Of Tuple(Of T1, T2)), ISourceBlock(Of Tuple(Of T1, T2))
类型参数
- T1
指定块的第一个目标接受的数据的类型。
- T2
指定块的第二个目标接受的数据的类型。
- 继承
-
JoinBlock<T1,T2>
- 实现
-
IDataflowBlock IReceivableSourceBlock<Tuple<T1,T2>> ISourceBlock<Tuple<T1,T2>> ISourceBlock<TOutput>
注解
注释
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。
构造函数
| 名称 | 说明 |
|---|---|
| JoinBlock<T1,T2>() |
初始化新的 JoinBlock<T1,T2>。 |
| JoinBlock<T1,T2>(GroupingDataflowBlockOptions) |
初始化新的 JoinBlock<T1,T2>。 |
属性
| 名称 | 说明 |
|---|---|
| Completion |
获取一个 Task 表示数据流块的异步操作和完成。 |
| OutputCount |
获取可从此块接收的输出项数。 |
| Target1 |
获取可用于提供第一种类型的消息的目标。 |
| Target2 |
获取可用于提供第二种类型的消息的目标。 |
方法
| 名称 | 说明 |
|---|---|
| Complete() |
信号 IDataflowBlock 表明,它不应接受或生成更多消息,也不应再使用任何推迟的消息。 |
| Equals(Object) |
确定指定的对象是否等于当前对象。 (继承自 Object) |
| GetHashCode() |
用作默认哈希函数。 (继承自 Object) |
| GetType() |
获取当前实例的 Type。 (继承自 Object) |
| LinkTo(ITargetBlock<Tuple<T1,T2>>, DataflowLinkOptions) |
链接到 ISourceBlock<TOutput> 指定的 ITargetBlock<TInput> 。 |
| MemberwiseClone() |
创建当前 Object的浅表副本。 (继承自 Object) |
| ToString() |
返回一个字符串,表示此 IDataflowBlock 实例的格式名称。 |
| TryReceive(Predicate<Tuple<T1,T2>>, Tuple<T1,T2>) |
尝试从 < |
| TryReceiveAll(IList<Tuple<T1,T2>>) |
尝试从 < |