BatchBlock<T> Classe

Definição

Espaço de Nomes:: System.Threading.Tasks.Dataflow

Assemblagem:: System.Threading.Tasks.Dataflow.dll

Importante

Algumas informações dizem respeito a um produto pré-lançado que pode ser substancialmente modificado antes de ser lançado. A Microsoft não faz garantias, de forma expressa ou implícita, em relação à informação aqui apresentada.

Fornece um bloco de fluxo de dados que agrupa entradas em arrays.

generic <typename T>
public ref class BatchBlock sealed : System::Threading::Tasks::Dataflow::IPropagatorBlock<T, cli::array <T> ^>, System::Threading::Tasks::Dataflow::IReceivableSourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<cli::array <T> ^>, System::Threading::Tasks::Dataflow::ITargetBlock<T>

public sealed class BatchBlock<T> : System.Threading.Tasks.Dataflow.IPropagatorBlock<T,T[]>, System.Threading.Tasks.Dataflow.IReceivableSourceBlock<T[]>, System.Threading.Tasks.Dataflow.ISourceBlock<T[]>, System.Threading.Tasks.Dataflow.ITargetBlock<T>

type BatchBlock<'T> = class
    interface IPropagatorBlock<'T, 'T[]>
    interface ITargetBlock<'T>
    interface IDataflowBlock
    interface ISourceBlock<'T[]>
    interface IReceivableSourceBlock<'T[]>

Public NotInheritable Class BatchBlock(Of T)
Implements IPropagatorBlock(Of T, T()), IReceivableSourceBlock(Of T()), ISourceBlock(Of T()), ITargetBlock(Of T)

Parâmetros de Tipo Genérico

T

Especifica o tipo de dados colocados em lotes.

Herança: Object
BatchBlock<T>

Implementações: IDataflowBlock IPropagatorBlock<T,T[]> IReceivableSourceBlock<T[]> ISourceBlock<T[]> ISourceBlock<TOutput> ITargetBlock<T> ITargetBlock<TInput>

Observações

Note

A biblioteca de fluxo de dados TPL (o namespace System.Threading.Tasks.Dataflow) não é distribuída com o .NET. Para instalar o namespace System.Threading.Tasks.Dataflow no Visual Studio, abra o seu projeto, escolha Gerir Pacotes NuGet no menu Projeto e pesquise o pacote System.Threading.Tasks.Dataflow online. Como alternativa, para instalá-lo usando a CLI do .NET Core, execute dotnet add package System.Threading.Tasks.Dataflow.

Construtores

Name	Description
BatchBlock<T>(Int32, GroupingDataflowBlockOptions)	Inicializa um novo BatchBlock<T> com o tamanho de lote especificado, opção declinante e opções de bloco.
BatchBlock<T>(Int32)	Inicializa um novo BatchBlock<T> com o tamanho de lote especificado.

Propriedades

Name	Description
BatchSize	Obtém o tamanho dos lotes gerados por este BatchBlock<T>.
Completion	Obtém-se a Task que representa a operação assíncrona e a conclusão do bloco de fluxo de dados.
OutputCount	Obtém o número de itens de saída disponíveis para serem recebidos deste bloco.

Métodos

Name	Description
Complete()	Sinais para o IDataflowBlock grupo de que não deve aceitar nem produzir mais mensagens nem consumir mais mensagens adiadas.
Equals(Object)	Determina se o objeto especificado é igual ao objeto atual. (Herdado de Object)
GetHashCode()	Serve como função de hash predefinida. (Herdado de Object)
GetType()	Obtém o Type da instância atual. (Herdado de Object)
LinkTo(ITargetBlock<T[]>, DataflowLinkOptions)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> .
MemberwiseClone()	Cria uma cópia superficial do atual Object. (Herdado de Object)
ToString()	Devolve uma cadeia que representa o nome formatado desta IDataflowBlock instância.
TriggerBatch()	Desencadeia a BatchBlock<T> iniciação de uma operação de agrupamento mesmo que o número de itens atualmente em fila ou adiados seja inferior ao BatchSize.
TryReceive(Predicate<T[]>, T[])	Tentativas de receber síncronicamente um item de saída disponível do IReceivableSourceBlock<TOutput>.
TryReceiveAll(IList<T[]>)	Tentativas de receber síncronicamente todos os itens disponíveis do IReceivableSourceBlock<TOutput>.

Implementações de Interface Explícita

Name	Description
IDataflowBlock.Fault(Exception)	Faz com que a IDataflowBlock conclua num Faulted estado.
ISourceBlock<T[]>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T[]>, Boolean)	Chamado por um link ITargetBlock<TInput> para aceitar e consumir um DataflowMessageHeader anteriormente oferecido por este ISourceBlock<TOutput> .
ISourceBlock<T[]>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T[]>)	Chamado por um link ITargetBlock<TInput> para libertar um anteriormente reservado DataflowMessageHeader por este ISourceBlock<TOutput>.
ISourceBlock<T[]>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T[]>)	Chamado por um ligado ITargetBlock<TInput> para reservar um já oferecido DataflowMessageHeader por isto ISourceBlock<TOutput>.
ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean)	Oferece uma mensagem ao ITargetBlock<TInput>, dando ao alvo a oportunidade de consumir ou adiar a mensagem.

Métodos da Extensão

Name	Description
AsObservable<TOutput>(ISourceBlock<TOutput>)	Cria uma nova IObservable<T> abstração sobre o ISourceBlock<TOutput>.
AsObserver<TInput>(ITargetBlock<TInput>)	Cria uma nova IObserver<T> abstração sobre o ITargetBlock<TInput>.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput> usando o filtro especificado.
LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>)	Liga o ISourceBlock<TOutput> ao especificado ITargetBlock<TInput>.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	Fornece um Task<TResult> que monitoriza assíncronamente a fonte para a saída disponível.
OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>)	Fornece um Task<TResult> que monitoriza assíncronamente a fonte para a saída disponível.
Post<TInput>(ITargetBlock<TInput>, TInput)	Publica um item no ITargetBlock<TInput>arquivo .
Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken)	O Synchroniously recebe um valor de uma fonte especificada e fornece um token para cancelar a operação.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	Synchronally recebe um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo opcional de time-out.
Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan)	Sincronizadamente recebe um valor de uma fonte especificada, observando um período opcional de time-out.
Receive<TOutput>(ISourceBlock<TOutput>)	Recebe síncronicamente um valor de uma fonte especificada.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken)	De forma assíncrona, recebe um valor de uma fonte especificada e fornece um token para cancelar a operação.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken)	De forma assíncrona, recebe um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo opcional de time-out.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan)	De forma assíncrona, recebe um valor de uma fonte especificada, observando um período opcional de time-out.
ReceiveAsync<TOutput>(ISourceBlock<TOutput>)	De forma assíncrona, recebe um valor de uma fonte especificada.
SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken)	Assíncrono, oferece uma mensagem ao bloco de mensagens alvo, permitindo adiamento.
SendAsync<TInput>(ITargetBlock<TInput>, TInput)	Assíncrono, oferece uma mensagem ao bloco de mensagens alvo, permitindo adiamento.
TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput)	Tentativas de receber síncronicamente um item do ISourceBlock<TOutput>.

Aplica-se a

Comentários

Esta página foi útil?