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

namespace AsyncFile
{
  class Program
  {
    static void Main(string[] args)
    {
      const int maxsize = 100000;
      ThreadPool.SetMaxThreads(1000,1000);
      PrintMessage("Main Thread start");

      // 初始化FileStream對(duì)象
      FileStream filestream = new FileStream("test.txt", FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.ReadWrite, 100, true);
      
      //打印文件流打開(kāi)的方式
      Console.WriteLine("filestream is {0} opened Asynchronously", filestream.IsAsync ? "" : "not");

      byte[] writebytes =new byte[maxsize];
      string writemessage = "An operation Use asynchronous method to write message.......................";
      writebytes = Encoding.Unicode.GetBytes(writemessage);
      Console.WriteLine("message size is： {0} byte\n", writebytes.Length);
      // 調(diào)用異步寫入方法比信息寫入到文件中
      filestream.BeginWrite(writebytes, 0, writebytes.Length, new AsyncCallback(EndWriteCallback), filestream);
      filestream.Flush();
      Console.Read();

    }

    // 當(dāng)把數(shù)據(jù)寫入文件完成后調(diào)用此方法來(lái)結(jié)束異步寫操作
    private static void EndWriteCallback(IAsyncResult asyncResult)
    {
      Thread.Sleep(500);
      PrintMessage("Asynchronous Method start");

      FileStream filestream = asyncResult.AsyncState as FileStream;

      // 結(jié)束異步寫入數(shù)據(jù)
      filestream.EndWrite(asyncResult);
      filestream.Close();
    }

    // 打印線程池信息
    private static void PrintMessage(String data)
    {
      int workthreadnumber;
      int iothreadnumber;

      // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量
      // 獲得的可用I/O線程數(shù)量給iothreadnumber變量
      ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);

      Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",
        data,
        Thread.CurrentThread.ManagedThreadId,
        Thread.CurrentThread.IsBackground.ToString(),
        workthreadnumber.ToString(),
        iothreadnumber.ToString());
    }
  }
}

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

namespace AsyncFileRead
{
  class Program
  {
    const int maxsize = 1024;
    static byte[] readbytes = new byte[maxsize];
    static void Main(string[] args)
    {
      ThreadPool.SetMaxThreads(1000, 1000);
      PrintMessage("Main Thread start");

      // 初始化FileStream對(duì)象
      FileStream filestream = new FileStream("test.txt", FileMode.OpenOrCreate, FileAccess.ReadWrite, FileShare.ReadWrite, 100, false);

      // 異步讀取文件內(nèi)容
      filestream.BeginRead(readbytes, 0, readbytes.Length, new AsyncCallback(EndReadCallback), filestream);
      Console.Read();
    }

    private static void EndReadCallback(IAsyncResult asyncResult)
    {
      Thread.Sleep(1000);
      PrintMessage("Asynchronous Method start");

      // 把AsyncResult.AsyncState轉(zhuǎn)換為State對(duì)象
      FileStream readstream = (FileStream)asyncResult.AsyncState;
      int readlength = readstream.EndRead(asyncResult);
      if (readlength <=0)
      {
        Console.WriteLine("Read error");
        return;
      }

      string readmessage = Encoding.Unicode.GetString(readbytes, 0, readlength);
      Console.WriteLine("Read Message is :" + readmessage);
      readstream.Close();
    }

    // 打印線程池信息
    private static void PrintMessage(String data)
    {
      int workthreadnumber;
      int iothreadnumber;

      // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量
      // 獲得的可用I/O線程數(shù)量給iothreadnumber變量
      ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);

      Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",
        data,
        Thread.CurrentThread.ManagedThreadId,
        Thread.CurrentThread.IsBackground.ToString(),
        workthreadnumber.ToString(),
        iothreadnumber.ToString());
    }
  }
}

using System;
using System.Net;
using System.Threading;

namespace RequestSample
{
  class Program
  {
    static void Main(string[] args)
    {
      ThreadPool.SetMaxThreads(1000, 1000);
      PrintMessage("Main Thread start");

      // 發(fā)出一個(gè)異步Web請(qǐng)求
      WebRequest webrequest =WebRequest.Create("http://www.cnblogs.com/");
      webrequest.BeginGetResponse(ProcessWebResponse, webrequest);

      Console.Read();
    }

    // 回調(diào)方法
    private static void ProcessWebResponse(IAsyncResult result)
    {
      Thread.Sleep(500);
      PrintMessage("Asynchronous Method start");

      WebRequest webrequest = (WebRequest)result.AsyncState;
      using (WebResponse webresponse = webrequest.EndGetResponse(result))
      {      
        Console.WriteLine("Content Length is : "+webresponse.ContentLength);
      }
    }

    // 打印線程池信息
    private static void PrintMessage(String data)
    {
      int workthreadnumber;
      int iothreadnumber;

      // 獲得線程池中可用的線程，把獲得的可用工作者線程數(shù)量賦給workthreadnumber變量
      // 獲得的可用I/O線程數(shù)量給iothreadnumber變量
      ThreadPool.GetAvailableThreads(out workthreadnumber, out iothreadnumber);

      Console.WriteLine("{0}\n CurrentThreadId is {1}\n CurrentThread is background :{2}\n WorkerThreadNumber is:{3}\n IOThreadNumbers is: {4}\n",
        data,
        Thread.CurrentThread.ManagedThreadId,
        Thread.CurrentThread.IsBackground.ToString(),
        workthreadnumber.ToString(),
        iothreadnumber.ToString());
    }
  }
}