• <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年2月>
            2930311234
            567891011
            12131415161718
            19202122232425
            26272829123
            45678910

            常用鏈接

            留言簿

            隨筆分類

            隨筆檔案

            搜索

            •  

            最新評論

            閱讀排行榜

            評論排行榜

                  ZThread中,有個抽象基類Runnable,提供了一個公共接口來執行任務:

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

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

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

                  要使用一個線程,必須要先初始化一個線程,并用Runnable* 類型的對象來構造該線程。該線程在構造函數中會自動調用run()函數,此時,main()函數與run()函數齊飛,秋水共長天一色。

            請時刻記住,多線程的程序跟普通程序有不同之處,請看下面一段代碼

            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是個局部變量,每次循環,t都會被自動釋放掉。這里會不會這個線程對象就沒有了呢?從結果上來看,答案是,不會!從原理上來看是,當創建了一個Thread對象的時候,相關聯的線程會在線程處理系統中自動注冊,并保持其活動狀態?;跅5膶ο蟊粧仐?,但是線程本身還是活在線程處理系統中。

                   如果這么說的話,那么這種情況就有點像,t是一個引用,指向線程處理系統中的實際對象。引用被咔嚓掉,實例還在。從結果上看是這樣的。我這么解釋,是便于理解。

            一個線程想做兩個任務的話是不行滴,做了個很無聊的實驗,想看看線程處理系統中的實際對象是個嘛
            Thread t(new test(1));
            Thread t(new test(1));
            //----------華麗麗的分割線-----------錯誤,t重定義了//

            {
              Thread t(new test(1));
            }
            {
              Thread t(new test(1));
            }
            //----------華麗麗的分割線-----------正常,兩個線程, 兩個不同的任務//

            test* tp = new test;// same task
            Thread t1(tp);
            Thread t2(tp);
            //----------華麗麗的分割線-----------非常正常,兩個線程完成一個任務// 
            以上實驗說明,棧上的名字真的不重要?。?!

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

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

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

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

                  執行器每次都要創建線程,比較耗時耗資源。另外一種方法就是一次創建一堆線程,等你要用的時候就從線程池里面去取。該方法用PoolExecutor,示例代碼:
            #include "zthread/PoolExecutor.h"
            ..
            ..
            ..
            PoolExecutor executor(5);
            for(int i = 0; i < 5; i++)
            executor.execute(new test(i));
            ..
            ..
            concurrentExecutor 所有的任務用一個線程,當一個任務執行完畢之后,后一個任務才開始執行,示例代碼:
            #include"zthread/ConcurrentExecutor.h"
            //..
            ConcurrentExecutor executor;
            for(int i = 0; i < 5; i++ )
            executor.execute(new test(i));//任務按提交順序執行,在下一個任務開始之前執行完成
            字體越來越小了      腫么回事

            讓步
            yield()告訴CPU, 我做完了要做的事情,你可以讓別人跑了。
            sleep()告訴CPU,  我累了,睡會覺,你可以讓別人先跑。
            設置優先級,告訴CPU,我們是有等級的,讓大佬先跑!!!代碼示例:

            #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);//成員

            哎,有了等級,大家就更有順序了“讓領導先走!??!”

            總結:創建一個任務很簡單,重寫run就對了。讓一個線程執行一個任務很簡單,構造函數中放個任務指針就對了。想要輕松執行線程很簡單,用個executor幫你就對了。領導先走很簡單,設個優先級就對了。

            下一章:共享有限資源。

            posted on 2012-05-15 17:22 Dino-Tech 閱讀(505) 評論(1)  編輯 收藏 引用

            FeedBack:
            # re: Thinking in c++ -- 并發(1)定義任務,使用線程 2012-07-19 15:12 qq675976614
            同一個任務不可以被兩個線程完成的吧,線程會把它delete掉的 不管它是棧變量還是堆變量  回復  更多評論
              
            久久亚洲AV无码西西人体| 欧美与黑人午夜性猛交久久久| 一本大道久久香蕉成人网| 欧美亚洲国产精品久久| 久久99热这里只有精品国产| 久久中文骚妇内射| 精品久久久久久国产牛牛app| 色欲综合久久躁天天躁| 国产V亚洲V天堂无码久久久| 久久久精品久久久久特色影视| 亚洲午夜无码久久久久| 国产精品无码久久四虎| 久久婷婷五月综合97色一本一本 | 大美女久久久久久j久久| 亚洲国产成人久久一区久久| 久久精品麻豆日日躁夜夜躁| 亚洲人成无码久久电影网站| 少妇久久久久久久久久| 亚洲人成无码网站久久99热国产 | 久久久久99精品成人片牛牛影视| 一本一道久久综合狠狠老| 观看 国产综合久久久久鬼色 欧美 亚洲 一区二区| 欧美国产成人久久精品| 91久久九九无码成人网站| 国产成人无码久久久精品一| 精品久久久中文字幕人妻| 久久久久国产亚洲AV麻豆| 日本免费久久久久久久网站| 欧美喷潮久久久XXXXx| 思思久久99热免费精品6| 久久精品免费网站网| 久久国产成人午夜aⅴ影院| 美女写真久久影院| 伊人久久大香线蕉影院95| 久久精品这里热有精品| 久久久精品一区二区三区| 亚洲AV无码久久寂寞少妇| 97精品伊人久久久大香线蕉| 亚洲精品蜜桃久久久久久| 伊人久久精品无码二区麻豆| 天天躁日日躁狠狠久久 |