1

我读过很多文章说 IOCP 用于 BeginXX/EndXX 对调用。但是，当我对它们进行测试时，我的结果显示 IOCP 在 BeginExecuteReader 调用中不起作用，而在 BeginGetResponse 调用中它工作得很好。

我对这个结果感到非常困惑。谁能告诉我原因？我的测试代码有什么问题吗？

这是下面的测试：

  1. 使用 BeginGetResponse 进行测试

    代码：

    public static void IoThread2()
{
  ThreadPool.SetMinThreads(5, 3);
  ThreadPool.SetMaxThreads(5, 3);
  int w; int io;
  ThreadPool.GetAvailableThreads(out w, out io);
  int cid = Thread.CurrentThread.ManagedThreadId;
  Console.WriteLine("Begin:" + w.ToString() + ";" + io.ToString() + "; id = " + cid.ToString());
  ManualResetEvent waitHandle = new ManualResetEvent(false);
  WebRequest request = HttpWebRequest.Create("http://www.cnblogs.com/");
  AsyncCallback cb = new AsyncCallback(IOThread2CallBack);
  request.BeginGetResponse(cb, request);
  waitHandle.WaitOne();
}

public static void IOThread2CallBack(IAsyncResult ar)
{
 try
 {
     WebRequest request = (WebRequest)ar.AsyncState;
     int w2; int io2;
     ThreadPool.GetAvailableThreads(out w2, out io2);
     int cid2 = Thread.CurrentThread.ManagedThreadId;
     Console.WriteLine("End:" + w2.ToString() + ";" + io2.ToString() + "; id = " + cid2.ToString());
     var response = request.EndGetResponse(ar);
  }catch (Exception ex){ }
}

    结果：

    Begin:5;3; id = 10
End:5;2; id = 13

    一个 IO 线程用于执行回调。

  2. 使用 BeginExecuteReader 代码进行测试：

    public static void IoThread1()
{
     ThreadPool.SetMinThreads(5, 3);
     ThreadPool.SetMaxThreads(5, 3);
     int w; int io;
     ThreadPool.GetAvailableThreads(out w, out io);
     int cid = Thread.CurrentThread.ManagedThreadId;
     Console.WriteLine("Begin:" + w.ToString() + ";" + io.ToString() + "; id = " + 
                    cid.ToString());
     SqlConnection connection = new SqlConnection(connectionString);
     connection.Open();
     AsyncCallback da = new AsyncCallback(IoThreadCallBack);
     SqlCommand command = new SqlCommand(s_QueryDatabaseListScript, connection);
     IAsyncResult ir = command.BeginExecuteReader(da,                             
                          command,System.Data.CommandBehavior.CloseConnection);
     ManualResetEvent waitHandle = new ManualResetEvent(false);
     waitHandle.WaitOne();
}

public static void IoThreadCallBack(IAsyncResult ar)
{
 int w; int io;
 ThreadPool.GetAvailableThreads(out w, out io);
 int cid = Thread.CurrentThread.ManagedThreadId;
 Console.WriteLine("End:" + w.ToString() + ";" + io.ToString() + "; id = " +  
                   cid.ToString());
 SqlCommand command = (SqlCommand)ar.AsyncState;
 StringBuilder sb = new StringBuilder();
 try
 {
       using (SqlDataReader reader = command.EndExecuteReader(ar))
       {
            while (reader.Read())
            {
                sb.Append(reader.GetString(0)).Append("; ");
            }
       }
  }
  catch (Exception ex){ }
  finally
  {
       command.Connection.Close();  
  }
 }

    结果：

    Begin:5;3; id = 10
End:4;3; id = 7

    另一个工作线程被用来执行回调

有什么问题？

4

1 回答 1

0

你的复制品很有创意。这是一个有趣的案例。

尝试使用命令文本“WAITFOR DELAY '02:00';”启动 100 个 SqlCommands 并观察线程计数如何随着时间的推移而发展（启动一个打印统计信息的计时器）。

我的猜测是，我们将看到消耗的线程远少于 100 个（意味着这部分异步行为正在工作）。出于某种原因，SqlCommand 正在使用“错误的”线程池线程，但这可能根本不会降低可伸缩性。

于 2012-03-31T12:52:47.867 回答