• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            隨筆 - 55  文章 - 15  trackbacks - 0
            <2012年7月>
            24252627282930
            1234567
            891011121314
            15161718192021
            22232425262728
            2930311234

            常用鏈接

            留言簿

            隨筆分類

            隨筆檔案

            搜索

            •  

            最新評(píng)論

            閱讀排行榜

            評(píng)論排行榜

                  ZThread中,有個(gè)抽象基類Runnable,提供了一個(gè)公共接口來執(zhí)行任務(wù):

            class Runnable
            {
              public:
                virtual void run() = 0;
                vitural ~Runnable(){}
            };

                  只要從這個(gè)類繼承,并且重寫run()函數(shù),就可以定義一個(gè)任務(wù)了!!!即具備了多線程的基礎(chǔ)。

                  但是只是定義了一個(gè)任務(wù),它并不具有線程處理的能力。還要推它一把。

                  要使用一個(gè)線程,必須要先初始化一個(gè)線程,并用Runnable* 類型的對(duì)象來構(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{
               forint i = 0; i < 5; i++ )
                 Thread t(new test(i));//看這里看這里,小痘痘沒有了!!!
                }catch(Synchronization_Exception& e){
                 cerr << e.what() << endl;
                }
            }

            按理說,t是個(gè)局部變量,每次循環(huán),t都會(huì)被自動(dòng)釋放掉。這里會(huì)不會(huì)這個(gè)線程對(duì)象就沒有了呢?從結(jié)果上來看,答案是,不會(huì)!從原理上來看是,當(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)中。

                   如果這么說的話,那么這種情況就有點(diǎn)像,t是一個(gè)引用,指向線程處理系統(tǒng)中的實(shí)際對(duì)象。引用被咔嚓掉,實(shí)例還在。從結(jié)果上看是這樣的。我這么解釋,是便于理解。

            一個(gè)線程想做兩個(gè)任務(wù)的話是不行滴,做了個(gè)很無聊的實(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)說明,棧上的名字真的不重要!!!

            通過多線程,可以創(chuàng)建一個(gè)有響應(yīng)的用戶界面。具體程序就不在碼了,這里要說的是有兩個(gè)問題:1. 怎么退出一個(gè)線程 2. 線程間通信。
            1. 怎么退出?正常退出,強(qiáng)制退出(包括中斷),帶來的問題是,非正常退出的話資源不不會(huì)釋放?
            2. 線程間通信,發(fā)送一個(gè)信號(hào),讓子線程正常退出。

            考慮下面這段代碼:
            test* tp = new test;
            Thread t1(tp);
            delete tp;// 這相當(dāng)于釜底抽薪,太絕了

            千萬別這么做,除非你跟你的公司有不共戴天之仇。這么做的問題在于,你不知道你的線程正在用tp做多么重要的事情,突然tp就這么沒了,線程也會(huì)傻在那里。最終導(dǎo)致代碼的不穩(wěn)定。不穩(wěn)定懂么,公司都需要穩(wěn)定的代碼。
            那么想要一個(gè)線程停下來,就讓它自己決定是否應(yīng)該停,這時(shí)候它會(huì)清理現(xiàn)場(chǎng),釋放堆棧之類的,總之,妥妥的。
            總結(jié)就是:給他一個(gè)flag,讓他自己決定是否退出,千萬別隨便決定別人的命運(yùn)。

            使用執(zhí)行器簡(jiǎn)化工作
                  其實(shí)沒看出來有什么簡(jiǎn)化的,就是不用Thread的構(gòu)造函數(shù)了,用一個(gè)executor.execute(Runnable*)函數(shù)來做,該函數(shù)的參數(shù)也是一個(gè)Runnable類型的指針。語義上比較好理解了吧。還沒有理解其真正的涵義。

                  執(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í)行完成
            字體越來越小了      腫么回事

            讓步
            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 閱讀(504) 評(píng)論(1)  編輯 收藏 引用

            FeedBack:
            # re: Thinking in c++ -- 并發(fā)(1)定義任務(wù),使用線程 2012-07-19 15:12 qq675976614
            同一個(gè)任務(wù)不可以被兩個(gè)線程完成的吧,線程會(huì)把它delete掉的 不管它是棧變量還是堆變量  回復(fù)  更多評(píng)論
              

            只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            久久久久久久99精品免费观看| 久久久精品视频免费观看| 久久久艹| 久久精品国产一区二区| 狠狠狠色丁香婷婷综合久久俺| 久久久噜噜噜久久中文福利| 久久天天躁狠狠躁夜夜96流白浆| 国产成人精品三上悠亚久久| 精品久久久久久无码不卡| 久久这里的只有是精品23| 欧美黑人激情性久久| 亚洲色婷婷综合久久| 久久久久免费看成人影片| 国产精品免费看久久久| 久久精品人人做人人爽电影| 久久综合久久综合久久综合| 久久国产精品波多野结衣AV| 久久久久无码国产精品不卡| 日韩十八禁一区二区久久 | 国产亚洲精品美女久久久| 麻豆成人久久精品二区三区免费| 国产成人久久精品一区二区三区| WWW婷婷AV久久久影片| 国产精品免费看久久久香蕉| 久久久久亚洲AV综合波多野结衣| 一本色道久久综合| 久久精品中文无码资源站| 中文字幕亚洲综合久久2| 四虎亚洲国产成人久久精品| 中文字幕无码免费久久| 久久国产精品-久久精品| 久久久久99精品成人片| 伊人久久综合无码成人网 | 7777精品久久久大香线蕉| 久久久久亚洲av无码专区导航| 91亚洲国产成人久久精品| 久久久久人妻一区二区三区| 一本久久a久久精品综合夜夜| 麻豆av久久av盛宴av| 久久香蕉国产线看观看99| 国产美女亚洲精品久久久综合 |