C#编程总结（六）详解异步编程

使用 IAsyncResult 设计模式的异步操作是通过名为 Begin操作名称和End操作名称的两个方法来实现的，这两个方法分别开始和结束异步操作操作名称。例如，FileStream 类提供 BeginRead 和 EndRead 方法来从文件异步读取字节。这两个方法实现了 Read 方法的异步版本。在调用 Begin操作名称后，应用程序可以继续在调用线程上执行指令，同时异步操作在另一个线程上执行。每次调用 Begin操作名称 时，应用程序还应调用 End操作名称来获取操作的结果。Begin操作名称 方法开始异步操作操作名称并返回一个实现 IAsyncResult 接口的对象。 .NET Framework 允许您异步调用任何方法。定义与您需要调用的方法具有相同签名的委托；公共语言运行库将自动为该委托定义具有适当签名的 BeginInvoke 和 EndInvoke 方法。  

IAsyncResult 对象存储有关异步操作的信息。下表提供了有关异步操作的信息。

5、应用实例

案例1-读取文件

通常读取文件是一个比较耗时的工作，特别是读取大文件的时候，常见的上传和下载。但是我们又不想让用户一直等待，用户同样可以进行其他操作，可以使得系统有良好的交互性。这里我们写了同步调用和异步调用来进行比较说明。

读取文件类

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

namespace AsynSample
{
  class FileReader
  {
    /// <summary>
    /// 缓存池
    /// </summary>
    private byte[] Buffer { get; set; }
    /// <summary>
    /// 缓存区大小
    /// </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");
      //执行Endread时报错，fs已经释放，注意在异步中不能使用释放需要的资源
      //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);
        //读取结束
        stream.EndRead(ar);
        stream.Close();

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

								 
 2/4   首页 上一页 1 2 3 4 下一页 尾页