BufferBlock<T> Clase
Definición
Importante
Parte de la información hace referencia a la versión preliminar del producto, que puede haberse modificado sustancialmente antes de lanzar la versión definitiva. Microsoft no otorga ninguna garantía, explícita o implícita, con respecto a la información proporcionada aquí.
Proporciona un búfer para almacenar datos para un flujo de datos.
generic <typename T>
public ref class BufferBlock sealed : 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>public sealed class BufferBlock<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 BufferBlock<'T> = class
interface IPropagatorBlock<'T, 'T>
interface ITargetBlock<'T>
interface IDataflowBlock
interface ISourceBlock<'T>
interface IReceivableSourceBlock<'T>type BufferBlock<'T> = class
interface IDataflowBlock
interface IPropagatorBlock<'T, 'T>
interface ISourceBlock<'T>
interface ITargetBlock<'T>
interface IReceivableSourceBlock<'T>Public NotInheritable Class BufferBlock(Of T)
Implements IPropagatorBlock(Of T, T), IReceivableSourceBlock(Of T), ISourceBlock(Of T), ITargetBlock(Of T)Parámetros de tipo
- T
Especifica el tipo de los datos almacenados en búfer por este bloque de flujo de datos.
- Herencia
-
BufferBlock<T>
- Implementaciones
Constructores
| Nombre | Description |
|---|---|
| BufferBlock<T>() |
Inicializa un nuevo BufferBlock<T>. |
| BufferBlock<T>(DataflowBlockOptions) |
Inicializa un nuevo BufferBlock<T> con el DataflowBlockOptionsespecificado. |
Propiedades
| Nombre | Description |
|---|---|
| Completion |
Obtiene un Task objeto que representa la operación asincrónica y la finalización del bloque de flujo de datos. |
| Count |
Obtiene el número de elementos almacenados actualmente en el búfer. |
Métodos
| Nombre | Description |
|---|---|
| Complete() |
Señala a que IDataflowBlock no debe aceptar ni producir más mensajes ni consumir más mensajes pospuestos. |
| Equals(Object) |
Determina si el objeto especificado es igual al objeto actual. (Heredado de Object) |
| GetHashCode() |
Actúa como función hash predeterminada. (Heredado de Object) |
| GetType() |
Obtiene el Type de la instancia actual. (Heredado de Object) |
| LinkTo(ITargetBlock<T>, DataflowLinkOptions) |
Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput>. |
| MemberwiseClone() |
Crea una copia superficial del Objectactual. (Heredado de Object) |
| ToString() |
Devuelve una cadena que representa el nombre con formato de esta IDataflowBlock instancia. |
| TryReceive(Predicate<T>, T) |
Intenta recibir de forma sincrónica un elemento de salida disponible de .IReceivableSourceBlock<TOutput> |
| TryReceiveAll(IList<T>) |
Intenta recibir de forma sincrónica todos los elementos disponibles de IReceivableSourceBlock<TOutput>. |
Implementaciones de interfaz explícitas
| Nombre | Description |
|---|---|
| IDataflowBlock.Fault(Exception) |
Hace que se IDataflowBlock complete en un Faulted estado . |
| ISourceBlock<T>.ConsumeMessage(DataflowMessageHeader, ITargetBlock<T>, Boolean) |
Llamado por un vinculado ITargetBlock<TInput> para aceptar y consumir un DataflowMessageHeader objeto previamente ofrecido por este ISourceBlock<TOutput>. |
| ISourceBlock<T>.ReleaseReservation(DataflowMessageHeader, ITargetBlock<T>) |
Llamado por un vinculado ITargetBlock<TInput> para liberar un objeto reservado DataflowMessageHeader previamente por este ISourceBlock<TOutput>. |
| ISourceBlock<T>.ReserveMessage(DataflowMessageHeader, ITargetBlock<T>) |
Llamado por un vinculado ITargetBlock<TInput> para reservar un objeto ofrecido DataflowMessageHeader anteriormente por este ISourceBlock<TOutput>. |
| ITargetBlock<T>.OfferMessage(DataflowMessageHeader, T, ISourceBlock<T>, Boolean) |
Ofrece un mensaje a , ITargetBlock<TInput>lo que proporciona al destino la oportunidad de consumir o posponer el mensaje. |
Métodos de extensión
| Nombre | Description |
|---|---|
| AsObservable<TOutput>(ISourceBlock<TOutput>) |
Crea una nueva IObservable<T> abstracción sobre .ISourceBlock<TOutput> |
| AsObserver<TInput>(ITargetBlock<TInput>) |
Crea una nueva IObserver<T> abstracción sobre .ITargetBlock<TInput> |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, DataflowLinkOptions, Predicate<TOutput>) |
ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>, Predicate<TOutput>) |
ISourceBlock<TOutput> Vincula al especificado ITargetBlock<TInput> mediante el filtro especificado. |
| LinkTo<TOutput>(ISourceBlock<TOutput>, ITargetBlock<TOutput>) |
Vincula al ISourceBlock<TOutput> objeto especificado ITargetBlock<TInput>. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible. |
| OutputAvailableAsync<TOutput>(ISourceBlock<TOutput>) |
Proporciona un objeto Task<TResult> que supervisa de forma asincrónica el origen de la salida disponible. |
| Post<TInput>(ITargetBlock<TInput>, TInput) |
Publica un elemento en .ITargetBlock<TInput> |
| Receive<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recibe sincrónicamente un valor de un origen especificado y proporciona un token para cancelar la operación. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recibe sincrónicamente un valor de un origen especificado, proporcionando un token para cancelar la operación y observar un intervalo de tiempo de espera opcional. |
| Receive<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recibe sincrónicamente un valor de un origen especificado, observando un período de tiempo de espera opcional. |
| Receive<TOutput>(ISourceBlock<TOutput>) |
Recibe sincrónicamente un valor de un origen especificado. |
| ReceiveAllAsync<TOutput>(IReceivableSourceBlock<TOutput>, CancellationToken) |
Crea un objeto IAsyncEnumerable<T> que permite recibir todos los datos del origen. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, CancellationToken) |
Recibe de forma asincrónica un valor de un origen especificado y proporciona un token para cancelar la operación. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan, CancellationToken) |
Recibe de forma asincrónica un valor de un origen especificado, lo que proporciona un token para cancelar la operación y observar un intervalo de tiempo de espera opcional. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>, TimeSpan) |
Recibe de forma asincrónica un valor de un origen especificado, observando un período de tiempo de espera opcional. |
| ReceiveAsync<TOutput>(ISourceBlock<TOutput>) |
Recibe de forma asincrónica un valor de un origen especificado. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput, CancellationToken) |
Ofrece de forma asincrónica un mensaje al bloque de mensajes de destino, lo que permite posponer. |
| SendAsync<TInput>(ITargetBlock<TInput>, TInput) |
Ofrece de forma asincrónica un mensaje al bloque de mensajes de destino, lo que permite posponer. |
| TryReceive<TOutput>(IReceivableSourceBlock<TOutput>, TOutput) |
Intenta recibir de forma sincrónica un elemento de .ISourceBlock<TOutput> |
