Почему IOCP не работает в BeginExecuteReader - PullRequest
Новая
       4

Почему IOCP не работает в BeginExecuteReader

1 голос
/ 31 марта 2012

Я прочитал много статей, в которых говорится, что 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

    Один поток ввода-вывода использовался для выполнения обратного вызова.

  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

    Другой рабочий поток был использован для выполнения обратного вызова

В чем проблема?

1 Ответ

0 голосов
/ 31 марта 2012

Ваше репро очень креативно.Это интересный случай.

Попробуйте запустить 100 SqlCommands с текстом команды "WAITFOR DELAY '02: 00 ';"и понаблюдайте за тем, как происходит подсчет потоков с течением времени (запустите таймер, который печатает статистику).

Я предполагаю, что мы увидим, что потребляется гораздо меньше 100 потоков (то есть эта часть асинхронного поведения работает).По какой-то причине SqlCommand использует «неправильные» потоки пула потоков, но это может совсем не снизить масштабируемость.

...