AsyncPipeline Classe

Référence

Définition

Espace de noms:: Orleans.Runtime

Assembly:: Orleans.dll

Assembly:: Orleans.Core.dll

Paquet:: Microsoft.Orleans.Core v1.5.10

Paquet:: Microsoft.Orleans.Core v2.4.5

Paquet:: Microsoft.Orleans.Core v3.6.5

Source:: AsyncPipeline.cs

Important

Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.

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.

S’applique à

Partager via