AsyncPipeline Klasse

Definition

Namespace:

Orleans.Runtime

Assembly:

Orleans.Core.dll

Paket:

Microsoft.Orleans.Core v3.6.5

Quelle:

AsyncPipeline.cs

Eine Hilfsprogrammklasse, mit der die Rate der Generierung asynchroner Aktivitäten gesteuert werden kann. Verwaltet eine Pipeline mit asynchronen Vorgängen bis zu einer angegebenen maximalen Kapazität und blockiert den aufrufenden Thread, wenn die Pipeline zu tief wird, bevor queuierte Vorgänge nicht abgeschlossen werden. Fügt dem Aufrufer effektiv einen Gegendruck hinzu. Dies ist vor allem für Stresstests von Körnern unter kontrollierter Last nützlich und sollte niemals von einem Korncode aus verwendet werden!

public class AsyncPipeline : Orleans.Runtime.IPipeline

type AsyncPipeline = class
    interface IPipeline

Public Class AsyncPipeline
Implements IPipeline

Vererbung

Object

AsyncPipeline

Implementiert

IPipeline

Konstruktoren

AsyncPipeline()	Erstellt eine leere AsyncPipeline mit einer Kapazität, die der DefaultCapacity-Kapazität entspricht.
AsyncPipeline(Int32)	Erstellt eine leere AsyncPipeline mit einer angegebenen Kapazität.

Felder

DEFAULT_CAPACITY

Die Standardkapazität dieser AsyncPipeline. Entspricht 10.

Eigenschaften

Capacity	Die maximale Anzahl asynchroner Flugvorgänge, die in diese asynchrone Pipeline eingereiht werden können.
Count	Die Anzahl der Elemente, die derzeit in diese asynchrone Pipeline eingereiht werden.

Methoden

Add(Task)	Fügt dieser AsyncPipeline eine neue Aufgabe hinzu.
AddRange(IEnumerable<Task>)	Fügt dieser AsyncPipeline eine Auflistung von Aufgaben hinzu.
AddRange<T>(IEnumerable<Task<T>>)	Fügt dieser AsyncPipeline eine Auflistung von Aufgaben hinzu.
Wait()	Wartet, bis alle derzeit in der Warteschlange befindlichen asynchronen Vorgänge abgeschlossen sind. Blockiert den aufrufenden Thread.