DataflowBlock Classe
Definizione
Importante
Alcune informazioni sono relative alla release non definitiva del prodotto, che potrebbe subire modifiche significative prima della release definitiva. Microsoft non riconosce alcuna garanzia, espressa o implicita, in merito alle informazioni qui fornite.
Fornisce un set di metodi statici (Condivisi in Visual Basic) per l'uso dei blocchi di flussi di dati.
public ref class DataflowBlock abstract sealedpublic static class DataflowBlocktype DataflowBlock = classPublic Module DataflowBlock- Ereditarietà
-
DataflowBlock
Commenti
Note
La libreria del flusso di dati TPL (spazio dei nomi System.Threading.Tasks.Dataflow) non viene distribuita con .NET. Per installare lo spazio dei nomi System.Threading.Tasks.Dataflow in Visual Studio, aprire il progetto, scegliere Gestisci pacchetti NuGet dal menu Project e cercare online il pacchetto System.Threading.Tasks.Dataflow. In alternativa, per installarlo usando l'interfaccia della riga di comando di .NET Core, eseguire dotnet add package System.Threading.Tasks.Dataflow.
Metodi
| Nome | Descrizione |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crea una nuova IObservable<T> astrazione su ISourceBlock<TOutput>. |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Crea una nuova IObserver<T> astrazione su ITargetBlock<TInput>. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>, DataflowBlockOptions) |
Esegue il monitoraggio di tre origini del flusso di dati, richiamando prima il gestore fornito per qualsiasi origine rende disponibili i dati. |
| Choose<T1,T2,T3>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, ISourceBlock<T3>, Action<T3>) |
Esegue il monitoraggio di tre origini del flusso di dati, richiamando prima il gestore fornito per qualsiasi origine rende disponibili i dati. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>, DataflowBlockOptions) |
Esegue il monitoraggio di due origini del flusso di dati, richiamando il gestore fornito per qualsiasi origine rende prima disponibili i dati. |
| Choose<T1,T2>(ISourceBlock<T1>, Action<T1>, ISourceBlock<T2>, Action<T2>) |
Esegue il monitoraggio di due origini del flusso di dati, richiamando il gestore fornito per qualsiasi origine rende prima disponibili i dati. |
| Encapsulate<TInput,TOutput>(ITargetBlock<TInput>, ISourceBlock<TOutput>) |
Incapsula una destinazione e un'origine in un singolo propagatore. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput> utilizzando il filtro specificato. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Collega l'oggetto ISourceBlock<TOutput> all'oggetto specificato ITargetBlock<TInput>. |
| NullTarget<TInput>() |
Ottiene un blocco di destinazione che accetta in modo sincrono tutti i messaggi offerti e li elimina. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Fornisce un oggetto Task<TResult> che monitora in modo asincrono l'origine per l'output disponibile. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Inserisce un elemento nell'oggetto ITargetBlock<TInput>. |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Riceve in modo sincrono un valore da un'origine specificata e fornisce un token per annullare l'operazione. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Riceve in modo sincrono un valore da un'origine specificata, fornendo un token per annullare l'operazione e osservando un intervallo di timeout facoltativo. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Riceve in modo sincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Riceve in modo sincrono un valore da un'origine specificata. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Crea un oggetto IAsyncEnumerable<T> che consente di ricevere tutti i dati dall'origine. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Riceve in modo asincrono un valore da un'origine specificata e fornisce un token per annullare l'operazione. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Riceve in modo asincrono un valore da un'origine specificata, fornendo un token per annullare l'operazione e osservando un intervallo di timeout facoltativo. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Riceve in modo asincrono un valore da un'origine specificata, osservando un periodo di timeout facoltativo. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Riceve in modo asincrono un valore da un'origine specificata. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Offre in modo asincrono un messaggio al blocco di messaggi di destinazione, consentendo il posticipo. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Offre in modo asincrono un messaggio al blocco di messaggi di destinazione, consentendo il posticipo. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Tenta di ricevere in modo sincrono un elemento da ISourceBlock<TOutput>. |
