原本準(zhǔn)備在mongodb之后寫一個(gè)lucene.net系列,不過這幾天用到多線程時(shí)才發(fā)現(xiàn)自己對(duì)多線程的了解少之又少,僅僅停留在lock上面,,
故這幾天看了下線程參考手冊(cè)結(jié)合自己的心得整理一下放在博客上作為自己的學(xué)習(xí)筆記。
好了,,我們知道“負(fù)載”是一個(gè)很時(shí)尚,,很牛X的玩意,往大處說,,網(wǎng)站需要負(fù)載,,數(shù)據(jù)庫需要負(fù)載。往小處說,,線程也需要負(fù)載,,面對(duì)海量的
用戶請(qǐng)求,,我們的單線程肯定扛不住,那么怎么辦,,一定要負(fù)載,,所以說多線程是我們碼農(nóng)必須要熟練掌握的一門技術(shù)。
在framework中給我們提供了一個(gè)Threading命名空間,,下面是一個(gè)msdn上不完整的截圖:
在后面的系列中我也是主要整理這幾個(gè)類的使用方法和應(yīng)用場(chǎng)景,。
一:Thread的使用
我們知道這個(gè)類代表處理器線程,在Thread中有幾個(gè)比較常用和重要的方法,。
<1> sleep: 這個(gè)算是最簡(jiǎn)單的了,。
<2> join: 這個(gè)可以讓并發(fā)行處理變成串行化,什么意思呢,?上代碼說話最清楚,。
1 class Test
2 {
3 static void Main()
4 {
5 Thread t = new Thread(Run);
6
7 t.Start();
8
9 //Join相當(dāng)于把Run方法內(nèi)嵌如此
10 t.Join();
11
12 //該死的t.Join(),害的我主線程必須在你執(zhí)行完后才能執(zhí)行。
13 Console.WriteLine("我是主線程:" + Thread.CurrentThread.GetHashCode());
14 }
15
16 static void Run()
17 {
18 //等待5s
19 Thread.Sleep(5000);
20
21 Console.WriteLine("我是線程:" + Thread.CurrentThread.GetHashCode());
22 }
23 }
<3> Interrupt和Abort:這兩個(gè)關(guān)鍵字都是用來強(qiáng)制終止線程,,不過兩者還是有區(qū)別的,。
① Interrupt: 拋出的是 ThreadInterruptedException 異常。
Abort: 拋出的是 ThreadAbortException 異常,。
② Interrupt:如果終止工作線程,,只能管到一次,工作線程的下一次sleep就管不到了,,相當(dāng)于一個(gè)
contine操作,。
Abort:這個(gè)就是相當(dāng)于一個(gè)break操作,工作線程徹底死掉,。
Interrupt:
1 namespace Test
2 {
3 class Program
4 {
5 static void Main(string[] args)
6 {
7 Thread t = new Thread(new ThreadStart(Run));
8
9 t.Start();
10
11 //阻止動(dòng)作
12 t.Interrupt();
13
14 Console.Read();
15 }
16
17 static void Run()
18 {
19 for (int i = 1; i <= 3; i++)
20 {
21 Stopwatch watch = new Stopwatch();
22
23 try
24 {
25 watch.Start();
26 Thread.Sleep(2000);
27 watch.Stop();
28
29 Console.WriteLine("第{0}延遲執(zhí)行:{1}ms", i, watch.ElapsedMilliseconds);
30 }
31 catch (ThreadInterruptedException e)
32 {
33 Console.WriteLine("第{0}延遲執(zhí)行:{1}ms,不過拋出異常", i, watch.ElapsedMilliseconds);
34 }
35 }
36 }
37 }
38 }
Abort: 工作線程直接退出,,不帶走一片云彩。
1 namespace Test
2 {
3 class Program
4 {
5 static void Main(string[] args)
6 {
7 Thread t = new Thread(new ThreadStart(Run));
8
9 t.Start();
10
11 Thread.Sleep(100);
12
13 //阻止動(dòng)作
14 t.Abort();
15
16 Console.Read();
17 }
18
19 static void Run()
20 {
21 for (int i = 1; i <= 3; i++)
22 {
23 Stopwatch watch = new Stopwatch();
24
25 try
26 {
27 watch.Start();
28 Thread.Sleep(2000);
29 watch.Stop();
30
31 Console.WriteLine("第{0}延遲執(zhí)行:{1}ms", i, watch.ElapsedMilliseconds);
32 }
33 catch (ThreadAbortException e)
34 {
35 Console.WriteLine("第{0}延遲執(zhí)行:{1}ms,不過拋出異常", i, watch.ElapsedMilliseconds);
36 }
37 }
38 }
39 }
40 }
二:線程使用場(chǎng)景
可能線程的使用有點(diǎn)類似wcf,,做一些耗時(shí)但不很及時(shí)的需求,,比如可以開線程下圖片,連接數(shù)據(jù)庫等等,,當(dāng)然線程可以用來做負(fù)載,,這里就做
一個(gè)小demo,找一個(gè)美女網(wǎng)站,面對(duì)如此多的圖片,,一個(gè)線程真的吃不消啊,,
看了下網(wǎng)站主體上有4個(gè)tab頁,那么我們就開4個(gè)線程來負(fù)載
1 class Program
2 {
3 static void Main(string[] args)
4 {
5 string[] str = { "model", "sexy", "belle", "stars" };
6
7 for (int url = 0; url < str.Length; url++)
8 {
9 Thread thread = new Thread(DownLoad);
10
11 thread.Start(str[url]);
12 }
13 Console.Read();
14 }
15
16 public static void DownLoad(object category)
17 {
18 string url = string.Empty;
19
20 for (int purl = 9014; purl > 10; purl--)
21 {
22 for (int pageSize = 0; pageSize < 20; pageSize++)
23 {
24 try
25 {
26 if (pageSize == 0)
27 url = "http://www./" + category + "/" + purl + ".html";
28 else
29 url = "http://www./" + category + "/" + purl + "_" + pageSize + ".html";
30
31 //創(chuàng)建http鏈接
32 var request = (HttpWebRequest)WebRequest.Create(url);
33
34 request.Timeout = 1000 * 5; //5s過期
35
36 var response = (HttpWebResponse)request.GetResponse();
37
38 Stream stream = response.GetResponseStream();
39
40 StreamReader sr = new StreamReader(stream);
41
42 string content = sr.ReadToEnd();
43
44 var list = GetHtmlImageUrlList(content);
45
46 WebClient client = new WebClient();
47
48 string[] directory = { @"C:\MM\", @"D:\MM\", @"E:\MM\", @"F:\MM\" };
49
50 var directoryName = directory[new Random().Next(0, directory.Length)];
51
52 if (!Directory.Exists(directoryName))
53 Directory.CreateDirectory(directoryName);
54
55 var fileName = string.Empty;
56
57 if (list.Count == 0)
58 {
59 Console.WriteLine("時(shí)間:" + DateTime.Now + " 當(dāng)前網(wǎng)址:" + url + " 未發(fā)現(xiàn)圖片");
60 break;
61 }
62
63 try
64 {
65
66 fileName = category + "_" + purl + "_" + (pageSize + 1) + ".jpg";
67
68 var localFile = directoryName + fileName;
69
70 var imageRequest = (HttpWebRequest)WebRequest.Create(list[0]);
71
72 imageRequest.Timeout = 1000 * 5; //5s 超時(shí)
73
74 var imageResponse = (HttpWebResponse)imageRequest.GetResponse();
75
76 var s = imageResponse.GetResponseStream();
77
78 Image image = Image.FromStream(s);
79
80 image.Save(localFile);
81
82 image.Dispose();
83
84 Console.WriteLine("時(shí)間:" + DateTime.Now + " 圖片:" + fileName + " 已經(jīng)下載 存入磁盤位置:" + localFile);
85
86 }
87 catch (Exception e)
88 {
89 Console.WriteLine("時(shí)間:" + DateTime.Now + " 當(dāng)前圖片:" + fileName + " 錯(cuò)誤信息:" + e.Message);
90 continue;
91 }
92 }
93 catch (Exception ex)
94 {
95 Console.WriteLine("時(shí)間:" + DateTime.Now + " 當(dāng)前網(wǎng)址:" + url + " 錯(cuò)誤信息:" + ex.Message);
96 }
97 }
98 }
99 }
100
101 /// <summary>
102 /// 取得HTML中所有圖片的 URL,。
103 /// </summary>
104 /// <param name="sHtmlText">HTML代碼</param>
105 /// <returns>圖片的URL列表</returns>
106 public static List<string> GetHtmlImageUrlList(string sHtmlText)
107 {
108 // 定義正則表達(dá)式用來匹配 img 標(biāo)簽
109 Regex regImg = new Regex(@"<img\b[^<>]*?\bsrc[\s\t\r\n]*=[\s\t\r\n]*[""']?[\s\t\r\n]*(?<imgUrl>[^\s\t\r\n""'<>]*)[^<>]*?/?[\s\t\r\n]*>", RegexOptions.IgnoreCase);
110
111 // 搜索匹配的字符串
112 MatchCollection matches = regImg.Matches(sHtmlText);
113
114 List<string> sUrlList = new List<string>();
115
116 // 取得匹配項(xiàng)列表
117 foreach (Match match in matches)
118 sUrlList.Add(match.Groups["imgUrl"].Value);
119 return sUrlList;
120 }
121 }
三:對(duì)線程的一些思考
我們知道線程的優(yōu)點(diǎn)還是比較多的,,每個(gè)線程都需要默認(rèn)的堆棧空間,,所以說線程數(shù)受到內(nèi)存空間大小的限制,,如果線程數(shù)開的太多
反而適得其反,,進(jìn)程被分配的時(shí)間片會(huì)被線程分的更細(xì),也就導(dǎo)致了處理器需要更頻繁的在線程之間來回切換,。