Condividi tramite


AsyncPipeline Classe

Definizione

Classe di utilità helper che consente di controllare la frequenza di generazione di attività asincrone. Gestisce una pipeline di operazioni asincrone fino a una determinata capacità massima e blocca il thread chiamante se la pipeline diventa troppo profonda prima che le operazioni accodate non vengano completate. Aggiunge in modo efficace una pressione indietro al chiamante. Questo è utile principalmente per i grani di test di stress sotto carico controllato e non deve mai essere usato dall'interno di un codice granulare!

public class AsyncPipeline : Orleans.Runtime.IPipeline
type AsyncPipeline = class
    interface IPipeline
Public Class AsyncPipeline
Implements IPipeline
Ereditarietà
AsyncPipeline
Implementazioni

Costruttori

AsyncPipeline()

Costruisce un oggetto AsyncPipeline vuoto con capacità uguale a DefaultCapacity.

AsyncPipeline(Int32)

Costruisce un oggetto AsyncPipeline vuoto con una determinata capacità.

Campi

DEFAULT_CAPACITY

Capacità predefinita di questa AsyncPipeline. Uguale a 10.

Proprietà

Capacity

Numero massimo di operazioni asincrone in anteprima che possono essere accodate in questa pipeline asincrona.

Count

Numero di elementi attualmente accodati in questa pipeline asincrona.

Metodi

Add(Task)

Aggiunge una nuova attività a questa AsyncPipeline.

AddRange(IEnumerable<Task>)

Aggiunge una raccolta di attività a questa AsyncPipeline.

AddRange<T>(IEnumerable<Task<T>>)

Aggiunge una raccolta di attività a questa AsyncPipeline.

Wait()

Attende il completamento di tutte le operazioni asincrone attualmente in coda. Blocca il thread chiamante.

Si applica a