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

namespace AsynSample
{
  class FileReader
  {
    /// <summary>
    /// 緩存池
    /// </summary>
    private byte[] Buffer { get; set; }
    /// <summary>
    /// 緩存區(qū)大小
    /// </summary>
    public int BufferSize { get; set; }

    public FileReader(int bufferSize)
    {
      this.BufferSize = bufferSize;
      this.Buffer = new byte[BufferSize];
    }

    /// <summary>
    /// 同步讀取文件
    /// </summary>
    /// <param name="path">文件路徑</param>
    public void SynsReadFile(string path)
    {
      Console.WriteLine("同步讀取文件 begin");
      using (FileStream fs = new FileStream(path, FileMode.Open))
      {        
        fs.Read(Buffer, 0, BufferSize);
        string output = System.Text.Encoding.UTF8.GetString(Buffer);
        Console.WriteLine("讀取的文件信息：{0}",output);
      }
      
      Console.WriteLine("同步讀取文件 end");
    }
    /// <summary>
    /// 異步讀取文件
    /// </summary>
    /// <param name="path"></param>
    public void AsynReadFile(string path)
    {
      Console.WriteLine("異步讀取文件 begin");
      //執(zhí)行Endread時(shí)報(bào)錯(cuò)，fs已經(jīng)釋放，注意在異步中不能使用釋放需要的資源
      //using (FileStream fs = new FileStream(path, FileMode.Open))
      //{
      //  Buffer = new byte[BufferSize];
      //  fs.BeginRead(Buffer, 0, BufferSize, AsyncReadCallback, fs);
      //} 
      if (File.Exists(path))
      {
        FileStream fs = new FileStream(path, FileMode.Open);
        fs.BeginRead(Buffer, 0, BufferSize, AsyncReadCallback, fs);
      }
      else
      {
        Console.WriteLine("該文件不存在");
      }

    }
    /// <summary>
    /// 
    /// </summary>
    /// <param name="ar"></param>
    void AsyncReadCallback(IAsyncResult ar)
    {
      FileStream stream = ar.AsyncState as FileStream;
      if (stream != null)
      {
        Thread.Sleep(1000);
        //讀取結(jié)束
        stream.EndRead(ar);
        stream.Close();

        string output = System.Text.Encoding.UTF8.GetString(this.Buffer);
        Console.WriteLine("讀取的文件信息：{0}", output);
      }
    }
  }
}

using System;
using System.Threading;

namespace AsynSample
{
  class Program
  {
    static void Main(string[] args)
    {
      FileReader reader = new FileReader(1024);

      //改為自己的文件路徑
      string path = "C:\\Windows\\DAI.log";

      Console.WriteLine("開始讀取文件了...");
      //reader.SynsReadFile(path);

      reader.AsynReadFile(path);

      Console.WriteLine("我這里還有一大灘事呢.");
      DoSomething();
      Console.WriteLine("終于完事了，輸入任意鍵，歇著！");
      Console.ReadKey();      
    }
    /// <summary>
    /// 
    /// </summary>
    static void DoSomething()
    {
      Thread.Sleep(1000);
      for (int i = 0; i < 10000; i++)
      {
        if (i % 888 == 0)
        {
          Console.WriteLine("888的倍數(shù)：{0}",i);
        }
      }
    }
  }
}

public delegate string MyFunc(int num, DateTime dt);

using System;
using System.Text;

namespace AsynSample
{
  /// <summary>
  /// 下載委托
  /// </summary>
  /// <param name="fileName"></param>
  public delegate string AysnDownloadDelegate(string fileName);
  /// <summary>
  /// 通過(guò)委托實(shí)現(xiàn)異步調(diào)用
  /// </summary>
  class DownloadFile
  {
    /// <summary>
    /// 同步下載
    /// </summary>
    /// <param name="fileName"></param>
    public string Downloading(string fileName)
    {
      string filestr = string.Empty;
      Console.WriteLine("下載事件開始執(zhí)行");
      System.Threading.Thread.Sleep(3000);
      Random rand = new Random();
      StringBuilder builder =new StringBuilder();
      int num;
      for(int i=0;i<100;i++)
      {
        num = rand.Next(1000);
        builder.Append(i);
      }
      filestr = builder.ToString();
      Console.WriteLine("下載事件執(zhí)行結(jié)束");

      return filestr;
    }
    /// <summary>
    /// 異步下載
    /// </summary>
    public IAsyncResult BeginDownloading(string fileName)
    {
      string fileStr = string.Empty;
      AysnDownloadDelegate downloadDelegate = new AysnDownloadDelegate(Downloading);
      return downloadDelegate.BeginInvoke(fileName, Downloaded, downloadDelegate);
    }
    /// <summary>
    /// 異步下載完成后事件
    /// </summary>
    /// <param name="result"></param>
    private void Downloaded(IAsyncResult result)
    {
      AysnDownloadDelegate aysnDelegate = result.AsyncState as AysnDownloadDelegate;
      if (aysnDelegate != null)
      {
        string fileStr = aysnDelegate.EndInvoke(result);
        if (!string.IsNullOrEmpty(fileStr))
        {
          Console.WriteLine("下載文件：{0}", fileStr);
        }
        else
        {
          Console.WriteLine("下載數(shù)據(jù)為空!");
        }
      }
      else
      {
        Console.WriteLine("下載數(shù)據(jù)為空!");
      }
    }
  }
}