1     class Program
 2     {
 3         //把Asynchronous Processing設(shè)置為true
 4         static string connectionString = "Data Source=LESLIE-PC;Initial Catalog=Business;“+
 5                                          "Integrated Security=True;Asynchronous Processing=true";
 6 
 7         static void Main(string[] args)
 8         {
 9             //把CLR線(xiàn)程池最大線(xiàn)程數(shù)設(shè)置為1000
10             ThreadPool.SetMaxThreads(1000, 1000);
11             ThreadPoolMessage("Start");
12 
13             //使用WAITFOR DELAY命令來(lái)虛擬操作
14             SqlConnection connection = new SqlConnection(connectionString);
15             SqlCommand command = new SqlCommand("WAITFOR DELAY '0:0:3';", connection);
16             connection.Open();
17 
18             //啟動(dòng)異步SqlCommand操作，利用輪詢(xún)方式監(jiān)測(cè)操作
19             IAsyncResult result = command.BeginExecuteNonQuery();
20             ThreadPoolMessage("BeginRead");
21             while (!result.AsyncWaitHandle.WaitOne(500))
22                 Console.WriteLine("Main thread do work........");
23 
24             //結(jié)束異步SqlCommand
25             int count= command.EndExecuteNonQuery(result);
26             ThreadPoolMessage("\nCompleted");
27             Console.ReadKey();
28         }
29 
30         //顯示線(xiàn)程池現(xiàn)狀
31         static void ThreadPoolMessage(string data)
32         {
33             int a, b;
34             ThreadPool.GetAvailableThreads(out a, out b);
35             string message = string.Format("{0}\n  CurrentThreadId is {1}\n  "+
36                    "WorkerThreads is:{2}  CompletionPortThreads is :{3}\n",
37                    data, Thread.CurrentThread.ManagedThreadId, a.ToString(), b.ToString());
38             Console.WriteLine(message);
39         }
40     }

     class Program
     {
         //把Asynchronous Processing設(shè)置為true
         static string connectionString = "Data Source=LESLIE-PC;Initial Catalog=Business;”+
                                          “Integrated Security=True;Asynchronous Processing=true";
         static void Main(string[] args)
         {
             //把CLR線(xiàn)程池最大線(xiàn)程數(shù)設(shè)置為1000
             ThreadPool.SetMaxThreads(1000, 1000);
             ThreadPoolMessage("Start");
 
             //使用WAITFOR DELAY命令來(lái)虛擬操作
             SqlConnection connection = new SqlConnection(connectionString);
             SqlCommand command = new SqlCommand("WAITFOR DELAY '0:0:3';", connection);
             connection.Open();
             
             //啟動(dòng)異步SqlCommand操作，并把SqlCommand對(duì)象傳遞到回調(diào)函數(shù)
             IAsyncResult result = command.BeginExecuteNonQuery(
                                        new AsyncCallback(AsyncCallbackMethod),command);
             Console.ReadKey();
         }
 
         static void AsyncCallbackMethod(IAsyncResult result)
         {
             Thread.Sleep(200);
             ThreadPoolMessage("AsyncCallback");
             SqlCommand command = (SqlCommand)result.AsyncState;
             int count=command.EndExecuteNonQuery(result);
             command.Connection.Close();
         }
 
         //顯示線(xiàn)程池現(xiàn)狀
         static void ThreadPoolMessage(string data)
         {
             int a, b;
             ThreadPool.GetAvailableThreads(out a, out b);
             string message = string.Format("{0}\n  CurrentThreadId is {1}\n  "+
                   "WorkerThreads is:{2}  CompletionPortThreads is :{3}\n",
                   data, Thread.CurrentThread.ManagedThreadId, a.ToString(), b.ToString());
 
             Console.WriteLine(message);
         }
     }

億恩-天使(QQ:530997) 電話(huà) 037160135991 服務(wù)器租用，托管歡迎咨詢(xún)。