ProcesadorLecturaAsincronica.cs

// OrtizOL - xCSw - http://ortizol.blogspot.com

using System;
using System.IO;
using System.Threading;

namespace Receta.Multithreading.R0301
{
    public class ProcesadorLecturaAsincronica
    {
        private Stream inputStream;

        // Tamaño del búfer para lectura por bloques (2KB):
        private int tamanioBufer = 2048;

        // Obtiene y establece el tamaño del búfer:
        public int TamanioBufer
        {
            get
            {
                return tamanioBufer;
            }
            set
            {
                tamanioBufer = value;
            }
        }

        // Búfer de almacenamiento de datos leídos:
        private byte[] bufer;

        public ProcesadorLecturaAsincronica(string nombreArchivo)
        {
            bufer = new byte[tamanioBufer];

            // Apertura de archivo con lectura asincrónica (true):
            inputStream = new FileStream(nombreArchivo, FileMode.Open,
                                         FileAccess.Read, FileShare.Read,
                                         tamanioBufer, true);
        }

        // Inicia el proceso de lectura asincrónica:
        public void IniciarLectura()
        {
            inputStream.BeginRead(bufer, 0, bufer.Length,
                                  OnLecturaFinalizada, null);
        }

        // Callback una vez finalizada la lectura:
        private void OnLecturaFinalizada(IAsyncResult asyncResult)
        {
            int bytesLeidos = inputStream.EndRead(asyncResult);

            // Aún restan bytes por leer:
            if (bytesLeidos > 0)
            {
                // Simulación de operación de lectura larga:
                Console.WriteLine("\t[PROCESADOR ASINCRÓNICO]: Lectura de un bloque de datos.");
                Thread.Sleep(TimeSpan.FromMilliseconds(20));

                // Inicio de la lectura del siguiente bloque de forma asincrónica:
                inputStream.BeginRead(bufer, 0, bufer.Length, OnLecturaFinalizada, null);
            }
            else
            {
                // Fin del procesamiento>
                Console.WriteLine("\t[PROCESAOR ASINCRÓNICO]: Operación finalizada.");
                inputStream.Close();
            }
        }
    }
}