AsyncPipeline Classe

Définition

Espace de noms:

Orleans.Runtime

Assembly:

Orleans.Core.dll

Paquet:

Microsoft.Orleans.Core v3.6.5

Source:

AsyncPipeline.cs

Classe d’utilitaire d’assistance qui permet de contrôler le taux de génération d’activités asynchrones. Maintient un pipeline d’opérations asynchrones jusqu’à une capacité maximale donnée et bloque le thread appelant si le pipeline devient trop profond avant que les opérations en file d’attente ne soient pas terminées. Ajoute effectivement une contre-pression à l’appelant. Cela est principalement utile pour les tests de contrainte des grains sous une charge contrôlée et ne doit jamais être utilisé à partir d’un code de grain!

public class AsyncPipeline : Orleans.Runtime.IPipeline

type AsyncPipeline = class
    interface IPipeline

Public Class AsyncPipeline
Implements IPipeline

Héritage

Object

AsyncPipeline

Implémente

IPipeline

Constructeurs

AsyncPipeline()	Construit un AsyncPipeline vide avec une capacité égale à defaultCapacity.
AsyncPipeline(Int32)	Construit un AsyncPipeline vide avec une capacité donnée.

Champs

DEFAULT_CAPACITY

Capacité par défaut de cet AsyncPipeline. Est égal à 10.

Propriétés

Capacity	Nombre maximal d’opérations en cours d’exécution asynchrones pouvant être mises en file d’attente dans ce pipeline asynchrone.
Count	Nombre d’éléments actuellement mis en file d’attente dans ce pipeline asynchrone.

Méthodes

Add(Task)	Ajoute une nouvelle tâche à cette AsyncPipeline.
AddRange(IEnumerable<Task>)	Ajoute une collection de tâches à cet AsyncPipeline.
AddRange<T>(IEnumerable<Task<T>>)	Ajoute une collection de tâches à cet AsyncPipeline.
Wait()	Attend que toutes les opérations asynchrones actuellement mises en file d’attente soient terminées. Bloque le thread appelant.