BatchBlock<T> Osztály
Definíció
Fontos
Egyes információk olyan, kiadás előtti termékekre vonatkoznak, amelyek a kiadásig még jelentősen módosulhatnak. A Microsoft nem vállal kifejezett vagy törvényi garanciát az itt megjelenő információért.
Egy adatfolyamblokkot biztosít, amely tömbökbe köti a bemeneteket.
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)Típusparaméterek
- T
Megadja a kötegekbe helyezett adatok típusát.
- Öröklődés
-
BatchBlock<T>
- Megvalósítás
Megjegyzések
Note
A TPL-adatfolyamtár (a System.Threading.Tasks.Dataflow névtér) nincs elosztva a .NET-tel. Ha telepíteni szeretné a System.Threading.Tasks.Dataflow névteret a Visual Studióban, nyissa meg a projektet, válassza NuGet-csomagok kezelése a Project menüjében, és keressen online a System.Threading.Tasks.Dataflow csomagra. Másik lehetőségként a .NET Core CLI használatával telepítheti, futtassa a dotnet add package System.Threading.Tasks.Dataflow.
Konstruktorok
| Name | Description |
|---|---|
| BatchBlock<T>(Int32, GroupingDataflowBlockOptions) |
Inicializál egy újat BatchBlock<T> a megadott kötegmérettel, csökkenő beállítással és blokkbeállításokkal. |
| BatchBlock<T>(Int32) |
Inicializál egy újat BatchBlock<T> a megadott kötegmérettel. |
Tulajdonságok
| Name | Description |
|---|---|
| BatchSize |
Lekéri az ezzel BatchBlock<T>létrehozott kötegek méretét. |
| Completion |
Task Lekéri az adatfolyam-blokk aszinkron műveletét és befejezését ábrázoló értéket. |
| OutputCount |
Lekéri a blokkból fogadandó kimeneti elemek számát. |
Metódusok
| Name | Description |
|---|---|
| Complete() |
Azt jelzi IDataflowBlock , hogy nem fogadhat el és nem hozhat létre több üzenetet, és nem használ fel több elhalasztott üzenetet. |
| Equals(Object) |
Meghatározza, hogy a megadott objektum egyenlő-e az aktuális objektummal. (Öröklődés forrása Object) |
| GetHashCode() |
Ez az alapértelmezett kivonatoló függvény. (Öröklődés forrása Object) |
| GetType() |
Lekéri az Type aktuális példányt. (Öröklődés forrása Object) |
| LinkTo(ITargetBlock<T[]>, DataflowLinkOptions) |
A megadotthoz csatolja a ISourceBlock<TOutput> elemet ITargetBlock<TInput> . |
| MemberwiseClone() |
Az aktuális Objectpéldány sekély másolatát hozza létre. (Öröklődés forrása Object) |
| ToString() |
Egy sztringet ad vissza, amely a példány formázott nevét IDataflowBlock jelöli. |
| TriggerBatch() |
Akkor is aktiválja a BatchBlock<T> kötegelési műveletet, ha az aktuálisan várólistára helyezett vagy elhalasztott elemek száma kisebb, mint a BatchSize. |
| TryReceive(Predicate<T[]>, T[]) |
Egy elérhető kimeneti elem szinkronizálási kísérlete a IReceivableSourceBlock<TOutput>. |
| TryReceiveAll(IList<T[]>) |
Az összes rendelkezésre álló elem szinkron fogadására tett kísérletek a IReceivableSourceBlock<TOutput>. |
Explicit interfész-implementációk
Bővítő metódusok
| Name | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Új IObservable<T> absztrakciót hoz létre a ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Új IObserver<T> absztrakciót hoz létre a ITargetBlock<TInput>. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
A megadott szűrővel csatolja a ISourceBlock<TOutput> megadotthoz ITargetBlock<TInput> . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
A megadott szűrővel csatolja a ISourceBlock<TOutput> megadotthoz ITargetBlock<TInput> . |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
A megadotthoz csatolja a ISourceBlock<TOutput> elemet ITargetBlock<TInput>. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Task<TResult> A rendelkezésre álló kimenet forrását aszinkron módon figyeli. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Task<TResult> A rendelkezésre álló kimenet forrását aszinkron módon figyeli. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Elem bejegyzése a következőre: .> |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Szinkron módon kap egy értéket egy megadott forrástól, és egy jogkivonatot biztosít a művelet megszakításához. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Szinkron módon kap egy értéket egy megadott forrástól, amely egy jogkivonatot biztosít a művelet megszakításához és egy opcionális időtúllépési időköz megfigyeléséhez. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Szinkron módon kap egy értéket egy megadott forrástól, figyelembe véve az opcionális időtúllépési időszakot. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Szinkron módon kap egy értéket egy megadott forrásból. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Létrehoz egy olyan alkalmazást IAsyncEnumerable<T> , amely lehetővé teszi az összes adat fogadását a forrásból. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Aszinkron módon kap egy értéket egy megadott forrástól, és egy jogkivonatot biztosít a művelet megszakításához. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Aszinkron módon kap egy értéket egy megadott forrástól, amely jogkivonatot biztosít a művelet megszakításához és egy opcionális időtúllépési időköz megfigyeléséhez. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Aszinkron módon kap egy értéket egy megadott forrástól, egy opcionális időtúllépési időszakot figyelve. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Aszinkron módon egy adott forrásból kap értéket. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Aszinkron módon üzenetet küld a célüzenetblokknak, ami lehetővé teszi a halasztást. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Aszinkron módon üzenetet küld a célüzenetblokknak, ami lehetővé teszi a halasztást. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Megkísérli szinkronizálva fogadni az elemet a ISourceBlock<TOutput>. |
