AsyncPipeline 類別

定義

命名空間:

Orleans.Runtime

組件:

Orleans.Core.dll

套件:

Microsoft.Orleans.Core v3.6.5

來源:

AsyncPipeline.cs

協助程式公用程式類別，可控制非同步活動的產生速率。 維護非同步作業的管線，直到指定的最大容量為止，如果管線在排入佇列作業未完成之前太深，則會封鎖呼叫執行緒。 有效地將反向壓力新增至呼叫端。 這主要適用于受控制負載下的壓力測試細微性，且不應該從細微性程式碼內使用！

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()	等到所有目前排入佇列的非同步作業完成為止。 封鎖呼叫執行緒。