AsyncPipeline 类

定义

命名空间:

Orleans.Runtime

程序集:

Orleans.Core.dll

包:

Microsoft.Orleans.Core v3.6.5

Source:

AsyncPipeline.cs

一个帮助程序实用工具类，用于控制异步活动的生成速率。 将异步操作管道维护到给定的最大容量，如果管道在排队操作未完成之前变得太深，则阻止调用线程。 有效地向调用方增加背压。 这主要用于在受控负载下对粒度进行压力测试，绝不应在 grain 代码中使用！

public class AsyncPipeline : Orleans.Runtime.IPipeline

type AsyncPipeline = class
    interface IPipeline

Public Class AsyncPipeline
Implements IPipeline

继承

Object

AsyncPipeline

实现

IPipeline

构造函数

AsyncPipeline()	构造容量等于 DefaultCapacity 的空 AsyncPipeline。
AsyncPipeline(Int32)	构造具有给定容量的空 AsyncPipeline。

字段

DEFAULT_CAPACITY

此 AsyncPipeline 的默认容量。 等于 10。

属性

Capacity	可排队到此异步管道中的最大异步正在进行的操作数。
Count	当前排队进入此异步管道的项数。

方法

Add(Task)	向此 AsyncPipeline 添加新任务。
AddRange(IEnumerable<Task>)	将任务集合添加到此 AsyncPipeline。
AddRange<T>(IEnumerable<Task<T>>)	将任务集合添加到此 AsyncPipeline。
Wait()	等待当前所有排队的异步操作完成。 阻止调用线程。