Compartilhar via


AsyncPipeline Classe

Definição

Uma classe de utilitário auxiliar que permite controlar a taxa de geração de atividades assíncronas. Mantém um pipeline de operações assíncronas até uma determinada capacidade máxima e bloqueia o thread de chamada se o pipeline ficar muito profundo antes que as operações enfileiradas não sejam concluídas. Efetivamente adiciona uma pressão de retorno ao chamador. Isso é útil principalmente para granularidades de teste de estresse sob carga controlada e nunca deve ser usado de dentro de um código de granularidade!

public class AsyncPipeline : Orleans.Runtime.IPipeline
type AsyncPipeline = class
    interface IPipeline
Public Class AsyncPipeline
Implements IPipeline
Herança
AsyncPipeline
Implementações

Construtores

AsyncPipeline()

Constrói uma AsyncPipeline vazia com capacidade igual à DefaultCapacity.

AsyncPipeline(Int32)

Constrói uma AsyncPipeline vazia com uma determinada capacidade.

Campos

DEFAULT_CAPACITY

A capacidade padrão desse AsyncPipeline. É igual a 10.

Propriedades

Capacity

O número máximo de operações assíncronas em andamento que podem ser enfileiradas nesse pipeline assíncrono.

Count

O número de itens atualmente enfileirados nesse pipeline assíncrono.

Métodos

Add(Task)

Adiciona uma nova tarefa a este AsyncPipeline.

AddRange(IEnumerable<Task>)

Adiciona uma coleção de tarefas a este AsyncPipeline.

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

Adiciona uma coleção de tarefas a este AsyncPipeline.

Wait()

Aguarda até que todas as operações assíncronas enfileiradas no momento sejam concluídas. Bloqueia o thread de chamada.

Aplica-se a