BatchedJoinBlock<T1,T2> Classe
Definição
Fornece um bloco de fluxo de dados que processa em lotes um número especificado de entradas de possíveis tipos diferentes fornecidos a um ou mais de seus destinos.Provides a dataflow block that batches a specified number of inputs of potentially differing types provided to one or more of its targets.
generic <typename T1, typename T2>
public ref class BatchedJoinBlock sealed : System::Threading::Tasks::Dataflow::IReceivableSourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^>, System::Threading::Tasks::Dataflow::ISourceBlock<Tuple<System::Collections::Generic::IList<T1> ^, System::Collections::Generic::IList<T2> ^> ^>
public sealed class BatchedJoinBlock<T1,T2> : System.Threading.Tasks.Dataflow.IReceivableSourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>, System.Threading.Tasks.Dataflow.ISourceBlock<Tuple<System.Collections.Generic.IList<T1>,System.Collections.Generic.IList<T2>>>
type BatchedJoinBlock<'T1, 'T2> = class
interface IReceivableSourceBlock<IList<'T1> * IList<'T2>>
interface ISourceBlock<IList<'T1> * IList<'T2>>
interface IDataflowBlock
type BatchedJoinBlock<'T1, 'T2> = class
interface IDataflowBlock
interface IReceivableSourceBlock<IList<'T1> * IList<'T2>>
interface ISourceBlock<IList<'T1> * IList<'T2>>
Public NotInheritable Class BatchedJoinBlock(Of T1, T2)
Implements IReceivableSourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2))), ISourceBlock(Of Tuple(Of IList(Of T1), IList(Of T2)))
Parâmetros de tipo
- T1
Especifica o tipo de dados aceitos pelo primeiro destino do bloco.Specifies the type of data accepted by the block's first target.
- T2
Especifica o tipo de dados aceitos pelo segundo destino do bloco.Specifies the type of data accepted by the block's second target.
- Herança
-
BatchedJoinBlock<T1,T2>
- Implementações
-
IDataflowBlock IReceivableSourceBlock<Tuple<IList<T1>,IList<T2>>> ISourceBlock<Tuple<IList<T1>,IList<T2>>> ISourceBlock<TOutput>
Comentários
Observação
A Biblioteca de Fluxo de Dados TPL (o namespace System.Threading.Tasks.Dataflow) não é distribuída com o .NET.The TPL Dataflow Library (the System.Threading.Tasks.Dataflow namespace) is not distributed with .NET. Para instalar o namespace System.Threading.Tasks.Dataflow no Visual Studio, abra o projeto, escolha Gerenciar Pacotes NuGet no menu Projeto e pesquise online o pacote System.Threading.Tasks.Dataflow.To install the System.Threading.Tasks.Dataflow namespace in Visual Studio, open your project, choose Manage NuGet Packages from the Project menu, and search online for the System.Threading.Tasks.Dataflow package. Como alternativa, instale-o usando a CLI do .NET Core e execute dotnet add package System.Threading.Tasks.Dataflow.Alternatively, to install it using the .NET Core CLI, run dotnet add package System.Threading.Tasks.Dataflow.
Construtores
| BatchedJoinBlock<T1,T2>(Int32) |
Inicializa um novo BatchedJoinBlock<T1,T2> com a configuração especificada.Initializes a new BatchedJoinBlock<T1,T2> with the specified configuration. |
| BatchedJoinBlock<T1,T2>(Int32, GroupingDataflowBlockOptions) |
Inicializa um novo BatchedJoinBlock<T1,T2> com a configuração especificada.Initializes a new BatchedJoinBlock<T1,T2> with the specified configuration. |
Propriedades
| BatchSize |
Obtém o tamanho dos lotes gerados por este BatchedJoinBlock<T1,T2>.Gets the size of the batches generated by this BatchedJoinBlock<T1,T2>. |
| Completion |
Obtém um Task que representa a operação assíncrona e a conclusão do bloco de fluxo de dados.Gets a Task that represents the asynchronous operation and completion of the dataflow block. |
| OutputCount |
Obtém o número de itens de saída disponíveis para serem recebidos deste bloco.Gets the number of output items available to be received from this block. |
| Target1 |
Obtém um destino que pode ser usado para oferecer mensagens do primeiro tipo.Gets a target that may be used to offer messages of the first type. |
| Target2 |
Obtém um destino que pode ser usado para oferecer mensagens do segundo tipo.Gets a target that may be used to offer messages of the second type. |
Métodos
| Complete() |
Sinaliza para o IDataflowBlock que ele não deve aceitar nem produzir mais mensagens, e não deve consumir mais mensagens adiadas.Signals to the IDataflowBlock that it should not accept nor produce any more messages nor consume any more postponed messages. |
| Equals(Object) |
Determina se o objeto especificado é igual ao objeto atual.Determines whether the specified object is equal to the current object. (Herdado de Object) |
| GetHashCode() |
Serve como a função de hash padrão.Serves as the default hash function. (Herdado de Object) |
| GetType() |
Obtém o Type da instância atual.Gets the Type of the current instance. (Herdado de Object) |
| LinkTo(ITargetBlock<Tuple<IList<T1>,IList<T2>>>, DataflowLinkOptions) |
Vincula o ISourceBlock<TOutput> ao ITargetBlock<TInput> especificado.Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> . |
| MemberwiseClone() |
Cria uma cópia superficial do Object atual.Creates a shallow copy of the current Object. (Herdado de Object) |
| ToString() |
Retorna uma cadeia de caracteres que representa o nome formatado desta instância IDataflowBlock.Returns a string that represents the formatted name of this IDataflowBlock instance. |
| TryReceive(Predicate<Tuple<IList<T1>,IList<T2>>>, Tuple<IList<T1>,IList<T2>>) |
Tentativas de receber assincronamente um item de saída disponível do IReceivableSourceBlock<TOutput>.Attempts to synchronously receive an available output item from the IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<Tuple<IList<T1>,IList<T2>>>) |
Tentativas de receber assincronamente todos os itens disponíveis do IReceivableSourceBlock<TOutput>.Attempts to synchronously receive all available items from the IReceivableSourceBlock<TOutput>. |
Implantações explícitas de interface
Métodos de Extensão
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Cria uma nova abstração IObservable<T> em relação a ISourceBlock<TOutput>.Creates a new IObservable<T> abstraction over the ISourceBlock<TOutput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Vincula o ISourceBlock<TOutput> ao ITargetBlock<TInput> especificado.Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Vincula o ISourceBlock<TOutput> ao ITargetBlock<TInput> especificado usando o filtro indicado.Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> using the specified filter. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Vincula o ISourceBlock<TOutput> para o ITargetBlock<TInput> especificado usando o filtro indicado.Links the ISourceBlock<TOutput> to the specified ITargetBlock<TInput> using the specified filter. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fornece um Task<TResult> que monitora assincronamente a saída disponível na fonte.Provides a Task<TResult> that asynchronously monitors the source for available output. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fornece um Task<TResult> que monitora assincronamente a fonte de saída disponível.Provides a Task<TResult> that asynchronously monitors the source for available output. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Recebe de forma síncrona um valor de uma origem especificada.Synchronously receives a value from a specified source. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recebe de forma síncrona um valor de uma origem especificada e fornece um token para cancelar a operação.Synchronously receives a value from a specified source and provides a token to cancel the operation. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recebe de forma síncrona um valor de uma origem especificada, observando um período de tempo limite opcional.Synchronously receives a value from a specified source, observing an optional time-out period. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recebe de forma síncrona um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional.Synchronously receives a value from a specified source, providing a token to cancel the operation and observing an optional time-out interval. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Recebe assincronamente um valor de uma origem especificada.Asynchronously receives a value from a specified source. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recebe assincronamente um valor de uma origem especificada e fornece um token para cancelar a operação.Asynchronously receives a value from a specified source and provides a token to cancel the operation. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recebe assincronamente um valor de uma origem especificada, observando um período de tempo limite opcional.Asynchronously receives a value from a specified source, observing an optional time-out period. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recebe assincronamente um valor de uma fonte especificada, fornecendo um token para cancelar a operação e observando um intervalo de tempo limite opcional.Asynchronously receives a value from a specified source, providing a token to cancel the operation and observing an optional time-out interval. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tentativas de receber assincronamente um item do ISourceBlock<TOutput>.Attempts to synchronously receive an item from the ISourceBlock<TOutput>. |