C#線程系列講座(2)：Thread類的應(yīng)用

1、c#線程系列講r2)： thread類的應(yīng)用本文為原創(chuàng)，如需轉(zhuǎn)載，請(qǐng)注明作者和出處，謝謝!上一篇：c#線程系列講座(1)： beginlnvoke和endlnvoke方法一、thread類的基本用法通過system.threading.thread類可以開始新的線程，并在線程堆棧屮運(yùn)行靜態(tài)或?qū)嵗?方法?？梢酝ㄟ^thread類的的構(gòu)造方法傳遞一個(gè)無參數(shù)，并且不返回值(返回void)的委托 (threadstart),這個(gè)委托的定義如下:com visibleattribute(true)public delegate void threadstart()我們可以通過如下的方法來建立并運(yùn)行一個(gè)線程

2、。using system;using system.collectionsgeneric;using system.linq;using system.text;using system.threading;namespace mythreadclass programpublic static void mystaticthreadmethod()consolewriteline(nmystaticthreadmethodn );static void main(string args)thread threadl = new thread(mystaticthreadmethod);th

3、readl - start () ;/只要使用start方法，線程才會(huì)運(yùn)彳了除了運(yùn)行靜態(tài)的方法，述可以在線程中運(yùn)行實(shí)例方法，代碼如下：using system;using systemcollectionsgeneric;using system.linq;using system.text;using system.threading;namespace mythreadclass programpublic void mythreadmethod()console writeline (l,mythreadmethod,1);static void main(string args)thr

4、ead thread2 = new thread(new program().mythreadmethod);thread2.start();如果讀者的方法很簡(jiǎn)單，或出去某種冃的，也町以通過匿名委托或lambda表達(dá)式來為thread的構(gòu)造方法賦值，代碼如下：thread thread3 = new thread (delegate () console . writ eline (”)；);thread3start ();thread thread4 =new thread( ) => console.writeline(nlambdan)； )；thread4start ();其中l(wèi)

5、ambda表達(dá)式前面的()表示沒有參數(shù)。為了區(qū)分不同的線程，還可以為thread類的name屬性賦值，代碼如下：thread thread5 = new thread() => console.writeline(thread.currentt hread.name););thread5 name ="我的 lamdba11;thread5start ();如果將上面threadl至thread5放到一起執(zhí)行，由于系統(tǒng)對(duì)線程的調(diào)度不同，輸出的結(jié)果 是不定的，如圖1是一種可能的輸岀結(jié)果。eh c:tikd0tssystem32cmd. exeic t hre adme t ho

6、d 匿名委托 ”yt hreadmethod lambda表達(dá)式 嵌的lamdba 惰按任意鍵繼續(xù)圖1二、定義一個(gè)線程類我們口j以將thread類封裝在一個(gè)mythread類中，以使任何從mythread繼承的類都具有 多線程能力。mythread類的代碼如下：using system;using system.collections.generic;using system.linq;using system.text;using system.threading;namespace mythreadabsttmct class mythreadthread thread = null;ab

7、stract public void run();publie void start ()if (thread = null)thread = new thread(run); thread.start();可以用下血的代碼來使用mythread類。class newthread : mythreadoverride public void run ()console . writeline ( ”使用 mythread 建立并運(yùn)行線程");static void main(string args)newthread nt = new newthread();nt start ();

8、我們還町以利用mythread來為線程傳遞任意復(fù)雜的參數(shù)。詳細(xì)內(nèi)容見下節(jié)。三. 為線程傳遞參數(shù)thread類有-個(gè)帶參數(shù)的姿托類型的重載形式。這個(gè)姿托的定義如下:com visibleattribute( false)public delegate void parameterizedthreadstart(object obj)這個(gè)thread類的構(gòu)造方法的楚義如下：public thread(parameterizedthreadstart start);下面的代碼使用了這個(gè)帶參數(shù)的委托向線程傳遞-個(gè)字符串參數(shù)：public static void mystaticparamthreadm

9、ethod(object obj)console.writeline(obj);static void main(sargs)thread thread = new thread(mystmticparamthreadmethod);thread. start (n通過委托的參數(shù)傳值”);要注意的是，如果使用的是不帶參數(shù)的委托，不能使用帶參數(shù)的start方法運(yùn)行線程，否 則系統(tǒng)會(huì)拋出并常。但使用帶參數(shù)的委托，可以使用thread.start()來運(yùn)行線程，這時(shí)所傳遞 的參數(shù)值為null也可以定義一個(gè)類來傳遞參數(shù)值，如下面的代碼如下：class mydataprivate string dl;p

10、rivate int d2;public mydata(string dl, int d2)this.dl = dl;public void threadmethod()console.writeline(dl);console.writeline(d2);iyiydata mydata = new mydata ( na bed j 1234);thread thread = new thread(mydata.threadmethod);thread.start();如果使用在第二節(jié)定義的mythread類,傳遞參數(shù)會(huì)顯示更簡(jiǎn)單，代碼如下:class newthread : mythrea

11、dprivate string pl;private int p2;publie newthread(string pl, int p2)this.pl = pl;thisp2 = p2;override publie void run ()console.writeline(pl);console.writeline(p2);newthread newthread = new newthread ( nhello world11, 4321);newthread.start ();四、前臺(tái)和后臺(tái)線程使用thread建立的線程默認(rèn)情況下是前臺(tái)線程，在進(jìn)程屮，只要有一個(gè)前臺(tái)線程未退岀, 進(jìn)程就不

12、會(huì)終止。主線程就是一個(gè)前臺(tái)線程。而后臺(tái)線程不管線程是否結(jié)束，只要所有的前 臺(tái)線程都退出(包括正常退出和界常退出)后，進(jìn)程就會(huì)自動(dòng)終止。一般后臺(tái)線程用于處理 時(shí)間較短的任務(wù)，如在一個(gè)web服務(wù)器屮可以利用后臺(tái)線程來處理客戶端發(fā)過來的請(qǐng)求信 息。而前臺(tái)線程一般用于處理需要長時(shí)間等待的任務(wù)，如在web服務(wù)器中的監(jiān)聽客戶端請(qǐng) 求的程序，或是定時(shí)對(duì)某些系統(tǒng)資源進(jìn)行掃描的程序。下面的代碼演示了前臺(tái)和示臺(tái)線程的 區(qū)別。publie static void mystaticthreadmethod()threadsleep(3000);thread thread = new thread(mystaticth

13、readmethod);/ thread.isbackground = true;threadstart();如果運(yùn)行上而的代碼，程序會(huì)等待3秒后退出，如果將注釋去掉，將thread設(shè)成后臺(tái)線程，則程序會(huì)立即退出。要注意的是，必須在調(diào)用start方法z前設(shè)置線程的類型，否則一但線程運(yùn)行，將無法改變 其類型。通過beginxxx方法運(yùn)行的線程都是后臺(tái)線程。五、判斷多個(gè)線程是否都結(jié)束的兩種方法確定所有線程是否都完成了工作的方法有很多，如可以采用類似于對(duì)彖計(jì)數(shù)器的方法，所 謂対象計(jì)數(shù)器，就是一個(gè)對(duì)象被引川一次，這個(gè)計(jì)數(shù)器就加1,銷毀引用就減1,如果引川數(shù)為 0,則垃圾搜集器就會(huì)對(duì)這些引用數(shù)為0的對(duì)彖

14、進(jìn)行冋收。方法一：線程計(jì)數(shù)器線程也可以采用計(jì)數(shù)器的方法，即為所冇需要監(jiān)視的線程設(shè)一個(gè)線程計(jì)數(shù)器，每開始一個(gè)線程，在線程的執(zhí)行方法中為這個(gè)計(jì)數(shù)器加1,如果某個(gè)線程結(jié)束（在線程執(zhí)行方法的最后為這 個(gè)計(jì)數(shù)器減1）,為這個(gè)計(jì)數(shù)器減1。然后再開始一個(gè)線程，按著一定的時(shí)間間隔來監(jiān)視這個(gè)計(jì) 數(shù)器，如是棕個(gè)計(jì)數(shù)器為0,說明所有的線程都結(jié)束了。當(dāng)然，也可以不用這個(gè)監(jiān)視線程，而在 每一個(gè)工作線程的最后（在為計(jì)數(shù)器減1的代碼的后面）來監(jiān)視這個(gè)計(jì)數(shù)器，也就是說，每一 個(gè)工作線程在退岀z前，還婆負(fù)責(zé)檢測(cè)這個(gè)計(jì)數(shù)器。使用這種方法不要忘了同步這個(gè)計(jì)數(shù)器變最 啊，否則會(huì)產(chǎn)生意想不到的后果。方法二：使用thread.join方

15、法join方法只育在線程結(jié)束時(shí)才繼續(xù)執(zhí)行下面的語句?？梢詫?duì)每一個(gè)線程調(diào)用它的join方法, 但要注慧，這個(gè)調(diào)用要在另一個(gè)線程里，而不要在主線程，否則程序會(huì)被阻塞的。個(gè)人感覺這種方法比較好。線程計(jì)數(shù)器方法演示：class threadcounter : mythreadprivate static int count = 0;private int ms;private static void increment（）lock (typeof (threadcounter) )/ 必須同步計(jì)數(shù)器count+;private static void decrease ()lock (typeof (

16、threadcounter)count;private static int getcount()lock (typeof (threadcounter)return count;publie threadcounter(int ms)this.ms = ms;override publie void run()increment();thread.sleep(ms);console wr'iteline(ms.tost 匸ing() + ”亳不少任務(wù)結(jié)束”);decrease ();if (getcount() = 0)console . writeline ( ”所有任務(wù)結(jié)束”);

17、threadcounter counterl=newthreadcounter counter2=newthreadcounter counter3=newthreadcounter (3000);threadcounter (5000);threadcounter (7000);counterl.start ();counter2.start ();counter3.start ();上面的代碼雖然在大多數(shù)的時(shí)候町以止常工作，但卻存在一個(gè)隱患，就是如果某個(gè)線程， 假設(shè)是counterl,在運(yùn)行后，山于某些原因，其他的線程并未運(yùn)行，在這種情況下，在counterl 運(yùn)行完后，仍然可以顯示出“所

18、有任務(wù)結(jié)束”的提示信息，但是counter2和counter3還并未運(yùn) 行。為了消除這個(gè)隱患，可以將increment方法從run中移除，將其放到threadcounter的構(gòu) 造方法中，在這時(shí)，increment方法中的lock也】j以去掉了。代碼如：public threadcounter(int ms)this.ms = ms;increme nt();運(yùn)行上面的程序后，將顯示如圖2的結(jié)果。cc c:¥iroo¥ssystem32c>d. exeu 結(jié)結(jié)結(jié)續(xù) 務(wù)務(wù)務(wù)東繼 任任任結(jié)犍 000000亠憂 f0>0?0聽請(qǐng)使用thread.join方法演示private static void threadmethod(obj