16.13  实现异步文件I/O操作

让我们来看看如何使用异步方式和FileStream类型交互，以此结束对System.IO命名空间的研究。在研究多线程（见第14章）的时候，我们已经看过了.NET Framework提供的异步操作。因为I/O操作可能会花费很多时间，所有从System.IO.Stream派生的类型都有一组方法来实现数据异步操作。我们知道，这需要结合使用IAsyncResult类型：

 

public abstract class System.IO.Stream :

  MarshalByRefObject,

  IDisposable

{

...

  public virtual IAsyncResult BeginRead(byte[] buffer, int offset,

    int count, AsyncCallback callback, object state);

  public virtual IAsyncResult BeginWrite(byte[] buffer, int offset,

    int count, AsyncCallback callback, object state);

 

  public virtual int EndRead(IAsyncResult asyncResult);

  public virtual void EndWrite(IAsyncResult asyncResult);

}

 

派生自Stream的类型和异步委托、异步远程方法调用，在异步处理的工作原理上是一致的。然而，让异步行为大大提高文件访问速度是不太可能的，其他的流（比如：基于套接字的流）更有可能从异步处理上得到好处。接下来的例子将说明一种使用FileStream类型进行异步交互的方式。

 

class Program

{

  static void Main(string[] args)

  {

    Console.WriteLine("Main thread started. ThreadID = {0}",

      Thread.CurrentThread.GetHashCode());

 

        // 必须使用这个构造方法来得到一个支持异步读、写的 FileStream。

    FileStream fs = new FileStream("logfile.txt", FileMode.Append,

      FileAccess.Write, FileShare.None, 4096, true);

 

    string msg = "this is atest";

    byte[] buffer = Encoding.ASCII.GetBytes(msg);

 

        // 开始异步写操作，WriteDone方法在其完成后被调用。

        // 注意FileStream 对象作为一个状态信息被传递到回调方法中。

    fs.BeginWrite(buffer, 0, buffer.Length,

      new AsyncCallback(WriteDone), fs);

}

  private static void WriteDone(IAsyncResult ar)

  {

    Console.WriteLine("AsyncCallback method on ThreadID = {0}",

      Thread.CurrentThread.GetHashCode());

 

    Stream s = (Stream)ar.AsyncState;

    s.EndWrite(ar);

    s.Close();

  }

}

 

如果读者能回想起委托的运行过程，那么这个例子（对读者来说）的唯一兴趣点是为了让 FileStream 类型支持异步处理，必须使用一个（这里所显示的）特殊的构造函数。最后一个System.Boolean类型的参数（当它的值设置为true时）告诉FileStream对象在次线程上执行I/O的处理。