ZThread中，有個(gè)抽象基類Runnable，提供了一個(gè)公共接口來(lái)執(zhí)行任務(wù):
class Runnable
{
public:
virtual void run() = 0;
vitural ~Runnable(){}
};
只要從這個(gè)類繼承，并且重寫run（）函數(shù)，就可以定義一個(gè)任務(wù)了！！！即具備了多線程的基礎(chǔ)。
但是只是定義了一個(gè)任務(wù)，它并不具有線程處理的能力。還要推它一把。
要使用一個(gè)線程，必須要先初始化一個(gè)線程，并用Runnable* 類型的對(duì)象來(lái)構(gòu)造該線程。該線程在構(gòu)造函數(shù)中會(huì)自動(dòng)調(diào)用run（）函數(shù)，此時(shí)，main（）函數(shù)與run（）函數(shù)齊飛，秋水共長(zhǎng)天一色。
請(qǐng)時(shí)刻記住，多線程的程序跟普通程序有不同之處，請(qǐng)看下面一段代碼
class test : public Runnable
{
int id;
public:
test(int i = 0) : id(i){}
void run()
{
cout <<" Do Something " << endl;
}
};
int main()
{
try{
for( int i = 0; i < 5; i++ )
Thread t(new test(i));//看這里看這里，小痘痘沒有了！！！
}catch(Synchronization_Exception& e){
cerr << e.what() << endl;
}
}
按理說(shuō)，t是個(gè)局部變量，每次循環(huán)，t都會(huì)被自動(dòng)釋放掉。這里會(huì)不會(huì)這個(gè)線程對(duì)象就沒有了呢？從結(jié)果上來(lái)看，答案是，不會(huì)！從原理上來(lái)看是，當(dāng)創(chuàng)建了一個(gè)Thread對(duì)象的時(shí)候，相關(guān)聯(lián)的線程會(huì)在線程處理系統(tǒng)中自動(dòng)注冊(cè)，并保持其活動(dòng)狀態(tài)。基于棧的對(duì)象被拋棄，但是線程本身還是活在線程處理系統(tǒng)中。
如果這么說(shuō)的話，那么這種情況就有點(diǎn)像，t是一個(gè)引用，指向線程處理系統(tǒng)中的實(shí)際對(duì)象。引用被咔嚓掉，實(shí)例還在。從結(jié)果上看是這樣的。我這么解釋，是便于理解。
一個(gè)線程想做兩個(gè)任務(wù)的話是不行滴，做了個(gè)很無(wú)聊的實(shí)驗(yàn)，想看看線程處理系統(tǒng)中的實(shí)際對(duì)象是個(gè)嘛
Thread t(new test(1));
Thread t(new test(1));
//----------華麗麗的分割線-----------錯(cuò)誤，t重定義了//
{
Thread t(new test(1));
}
{
Thread t(new test(1));
}
//----------華麗麗的分割線-----------正常，兩個(gè)線程, 兩個(gè)不同的任務(wù)//
test* tp = new test;// same task
Thread t1(tp);
Thread t2(tp);
//----------華麗麗的分割線-----------非常正常，兩個(gè)線程完成一個(gè)任務(wù)//
以上實(shí)驗(yàn)說(shuō)明，棧上的名字真的不重要！！！
通過(guò)多線程，可以創(chuàng)建一個(gè)有響應(yīng)的用戶界面。具體程序就不在碼了，這里要說(shuō)的是有兩個(gè)問題：1. 怎么退出一個(gè)線程 2. 線程間通信。
1. 怎么退出？正常退出，強(qiáng)制退出（包括中斷），帶來(lái)的問題是，非正常退出的話資源不不會(huì)釋放？
2. 線程間通信，發(fā)送一個(gè)信號(hào)，讓子線程正常退出。
考慮下面這段代碼：
test* tp = new test;
Thread t1(tp);
delete tp;// 這相當(dāng)于釜底抽薪，太絕了
千萬(wàn)別這么做，除非你跟你的公司有不共戴天之仇。這么做的問題在于，你不知道你的線程正在用tp做多么重要的事情，突然tp就這么沒了，線程也會(huì)傻在那里。最終導(dǎo)致代碼的不穩(wěn)定。不穩(wěn)定懂么，公司都需要穩(wěn)定的代碼。
那么想要一個(gè)線程停下來(lái)，就讓它自己決定是否應(yīng)該停，這時(shí)候它會(huì)清理現(xiàn)場(chǎng)，釋放堆棧之類的，總之，妥妥的。
總結(jié)就是：給他一個(gè)flag，讓他自己決定是否退出，千萬(wàn)別隨便決定別人的命運(yùn)。
使用執(zhí)行器簡(jiǎn)化工作
其實(shí)沒看出來(lái)有什么簡(jiǎn)化的，就是不用Thread的構(gòu)造函數(shù)了，用一個(gè)executor.execute(Runnable*)函數(shù)來(lái)做，該函數(shù)的參數(shù)也是一個(gè)Runnable類型的指針。語(yǔ)義上比較好理解了吧。還沒有理解其真正的涵義。
執(zhí)行器每次都要?jiǎng)?chuàng)建線程，比較耗時(shí)耗資源。另外一種方法就是一次創(chuàng)建一堆線程，等你要用的時(shí)候就從線程池里面去取。該方法用PoolExecutor,示例代碼：
#include "zthread/PoolExecutor.h"
..
..
..
PoolExecutor executor(5);
for(int i = 0; i < 5; i++)
executor.execute(new test(i));
..
..
concurrentExecutor 所有的任務(wù)用一個(gè)線程，當(dāng)一個(gè)任務(wù)執(zhí)行完畢之后，后一個(gè)任務(wù)才開始執(zhí)行，示例代碼：
#include"zthread/ConcurrentExecutor.h"
//..
ConcurrentExecutor executor;
for(int i = 0; i < 5; i++ )
executor.execute(new test(i));//任務(wù)按提交順序執(zhí)行，在下一個(gè)任務(wù)開始之前執(zhí)行完成
字體越來(lái)越小了 腫么回事
讓步
yield（）告訴CPU， 我做完了要做的事情，你可以讓別人跑了。
sleep（）告訴CPU, 我累了，睡會(huì)覺，你可以讓別人先跑。
設(shè)置優(yōu)先級(jí)，告訴CPU，我們是有等級(jí)的，讓大佬先跑！！！代碼示例：
#include "zhread/Thread.h"
//..Something else
Thread high(new test(1));
Thread medium(new test(2));
Thread low(new test(3));
high.setPriority(High）；//總舵主
medium.setPriority(Medium);//分舵主
low.setPriority(Low);//成員
哎，有了等級(jí)，大家就更有順序了“讓領(lǐng)導(dǎo)先走！！！”
總結(jié)：創(chuàng)建一個(gè)任務(wù)很簡(jiǎn)單，重寫run就對(duì)了。讓一個(gè)線程執(zhí)行一個(gè)任務(wù)很簡(jiǎn)單，構(gòu)造函數(shù)中放個(gè)任務(wù)指針就對(duì)了。想要輕松執(zhí)行線程很簡(jiǎn)單，用個(gè)executor幫你就對(duì)了。領(lǐng)導(dǎo)先走很簡(jiǎn)單，設(shè)個(gè)優(yōu)先級(jí)就對(duì)了。下一章：共享有限資源。
posted on 2012-05-15 17:22
Dino-Tech 閱讀(505)
評(píng)論(1) 編輯 收藏 引用