BatchBlock<T> Klasa
Definicja
Ważne
Niektóre informacje odnoszą się do produktu w wersji wstępnej, który może zostać znacząco zmodyfikowany przed wydaniem. Firma Microsoft nie udziela żadnych gwarancji, jawnych lub domniemanych, w odniesieniu do informacji podanych w tym miejscu.
Udostępnia blok przepływu danych, który wsaduje dane wejściowe do tablic.
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[]>type BatchBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T[]>
interface ISourceBlock<'T[]>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T[]>Public NotInheritable Class BatchBlock(Of T)
Implements IPropagatorBlock(Of T, T()), IReceivableSourceBlock(Of T()), ISourceBlock(Of T()), ITargetBlock(Of T)Parametry typu
- T
Określa typ danych wsadowych.
- Dziedziczenie
-
BatchBlock<T>
- Implementuje
Uwagi
Uwaga
Biblioteka przepływów danych TPL ( System.Threading.Tasks.Dataflow przestrzeń nazw) nie jest dystrybuowana za pomocą platformy .NET. Aby zainstalować System.Threading.Tasks.Dataflow przestrzeń nazw w programie Visual Studio, otwórz projekt, wybierz pozycję Zarządzaj pakietami NuGet z menu Project i wyszukaj pakiet w trybie online System.Threading.Tasks.Dataflow . Aby zainstalować go przy użyciu interfejsu wiersza polecenia platformy .NET Core, uruchom polecenie dotnet add package System.Threading.Tasks.Dataflow.
Konstruktory
| BatchBlock<T>(Int32) |
Inicjuje nowy BatchBlock<T> o określonym rozmiarze partii. |
| BatchBlock<T>(Int32, GroupingDataflowBlockOptions) |
Inicjuje nowy BatchBlock<T> z określonym rozmiarem partii, opcją malejącą i opcjami bloku. |
Właściwości
| BatchSize |
Pobiera rozmiar partii wygenerowanych przez ten BatchBlock<T>element . |
| Completion |
Pobiera obiekt reprezentujący operację Task asynchroniczną i zakończenie bloku przepływu danych. |
| OutputCount |
Pobiera liczbę elementów wyjściowych dostępnych do odebrania z tego bloku. |
Metody
| Complete() |
Sygnały do IDataflowBlock tego, że nie powinny akceptować ani nie generować więcej komunikatów ani używać więcej odroczone komunikaty. |
| Equals(Object) |
Określa, czy dany obiekt jest taki sam, jak bieżący obiekt. (Odziedziczone po Object) |
| GetHashCode() |
Służy jako domyślna funkcja skrótu. (Odziedziczone po Object) |
| GetType() |
Type Pobiera wartość bieżącego wystąpienia. (Odziedziczone po Object) |
| LinkTo(ITargetBlock<T[]>, DataflowLinkOptions) |
Tworzy łącze ISourceBlock<TOutput> do określonego ITargetBlock<TInput> elementu . |
| MemberwiseClone() |
Tworzy płytkią kopię bieżącego Objectelementu . (Odziedziczone po Object) |
| ToString() |
Zwraca ciąg reprezentujący sformatowaną nazwę tego IDataflowBlock wystąpienia. |
| TriggerBatch() |
BatchBlock<T> Wyzwala element , aby zainicjować operację dzielenia na partie, nawet jeśli liczba aktualnie znajdujących się w kolejce lub odroczonych elementów jest mniejsza niż BatchSize. |
| TryReceive(Predicate<T[]>, T[]) |
Próbuje synchronicznie odebrać dostępny element wyjściowy z elementu IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<T[]>) |
Próbuje synchronicznie odbierać wszystkie dostępne elementy z elementu IReceivableSourceBlock<TOutput>. |
Jawne implementacje interfejsu
Metody rozszerzania
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Tworzy nową IObservable<T> abstrakcję dla elementu ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Tworzy nową IObserver<T> abstrakcję dla elementu ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Tworzy łącze ISourceBlock<TOutput> do określonego ITargetBlock<TInput>elementu . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Łączy element z ISourceBlock<TOutput> określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Łączy element z ISourceBlock<TOutput> określonym ITargetBlock<TInput> filtrem przy użyciu określonego filtru. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Task<TResult> Zapewnia asynchroniczne monitorowanie źródła pod kątem dostępnych danych wyjściowych. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Task<TResult> Zapewnia asynchroniczne monitorowanie źródła pod kątem dostępnych danych wyjściowych. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publikuje element w elemencie ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Synchronicznie odbiera wartość z określonego źródła. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Synchronicznie odbiera wartość z określonego źródła i udostępnia token umożliwiający anulowanie operacji. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Synchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny okres limitu czasu. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Synchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału limitu czasu. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Tworzy obiekt IAsyncEnumerable<T> , który umożliwia odbieranie wszystkich danych ze źródła. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Asynchronicznie odbiera wartość z określonego źródła. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Asynchronicznie odbiera wartość z określonego źródła i udostępnia token umożliwiający anulowanie operacji. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Asynchronicznie odbiera wartość z określonego źródła, obserwując opcjonalny limit czasu. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Asynchronicznie odbiera wartość z określonego źródła, zapewniając token umożliwiający anulowanie operacji i obserwowanie opcjonalnego interwału limitu czasu. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Asynchronicznie oferuje komunikat do docelowego bloku komunikatów, co pozwala na odroczenie. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Asynchronicznie oferuje komunikat do docelowego bloku komunikatów, co pozwala na odroczenie. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Próbuje synchronicznie odebrać element z elementu ISourceBlock<TOutput>. |
