C#多线程---I/O线程实现异步请求

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Node.js›Node.js教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

一、场景

利用I/O线程来模拟浏览器对服务器请求的异步操作。

二、例子

 1 using System;
 2 using System.Collections.Generic;
 3 using System.Linq;
 4 using System.Net;
 5 using System.Text;
 6 using System.Threading;
 7 using System.Threading.Tasks;
 8 
 9 namespace IOThread
10 {
11     class Program
12     {
13         static void Main(string[] args)
14         {
15             Console.ForegroundColor = ConsoleColor.DarkGreen;
16             PrintThreadInfo("Print info in Main");
17             Console.ResetColor();
18             Console.WriteLine();
19 
20             // 发出一个异步Web请求
21             WebRequest webrequest = WebRequest.Create("http://www.cnblogs.com/");
22             webrequest.BeginGetResponse(ProcessWebResponse, webrequest);
23             Console.WriteLine("");
24 
25             Console.Read();
26         }
27         // 回调方法
28         private static void ProcessWebResponse(IAsyncResult result)
29         {
30             Thread.Sleep(500);
31             PrintThreadInfo("ProcessWebResponse Method start");
32 
33             WebRequest webrequest = (WebRequest)result.AsyncState;
34             using (WebResponse webresponse = webrequest.EndGetResponse(result))
35             {
36                 Console.WriteLine("Content Length is : " + webresponse.ContentLength);
37             }
38         }
39         private static void PrintThreadInfo(string info)
40         {
41             Console.WriteLine(info);
42             Console.WriteLine($"ThreadId:{Thread.CurrentThread.ManagedThreadId}\nIsBackgroundThread:{Thread.CurrentThread.IsBackground}\nIsThreadPoolThread:{Thread.CurrentThread.IsThreadPoolThread}");
43             int workerThread = 0;
44             int ioThread = 0;
45             ThreadPool.GetMaxThreads(out workerThread, out ioThread);
46             Console.WriteLine($"MaxWorkerThread:{workerThread}\nMaxIoThread:{ioThread}");
47             int workerThreadAvailable = 0;
48             int ioThreadAvailable = 0;
49             ThreadPool.GetAvailableThreads(out workerThreadAvailable, out ioThreadAvailable);
50             Console.WriteLine($"AvailableWorkerThread:{workerThreadAvailable}\nAvailableIoThread:{ioThreadAvailable}");
51         }
52     }
53 }