亚洲免费乱码视频,日韩 欧美 国产 动漫 一区,97在线观看免费视频播国产,中文字幕亚洲图片

      1. <legend id="ppnor"></legend>

      2. 
        
        <sup id="ppnor"><input id="ppnor"></input></sup>
        <s id="ppnor"></s>

        Visual C++本地并行編程中的狀態(tài)管理

        字號:


            任務組取消
            新的Beta1 PPL的其中一個功能就是可以取消正在運行中的任務組。在task_group類型上加入run 和 wait方法是一個新的cancel方法。還有一個相應的is_canceling方法讓你可以檢查在進程中是否完成取消。 task_group_status列舉也有一個新的值叫做canceled,讓你檢查取消是否發(fā)生。以下的代碼展示了這些新的功能:
            //declare tasks and run tasks
            task_group tg;
            tg.run(([]{printf("consoleWrite0\n");}));
            tg.run(([]{printf("consoleWrite1\n");}));
            //cancel tasks
            tg.cancel();
            //check whether tasks are being cancelled
            bool taskGroupIsCanceling = tg.is_canceling();
            //check on status of task group
            task_group_status status = tg.wait();
            if (status == completed){
            printf("Tasks were completed successfully\n");
            }
            else if (status == canceled){
            printf("Tasks were canceled during task execution\n");
            }
            else{
            printf("An exception occured during task execution\n");
            }
            Combinable 類型
            達到并行執(zhí)行編程任務的最大利益的有效形式之一是工作在本地拷貝或是子數(shù)據(jù)上的每一個并行分支被處理,然后當處理結(jié)束后,將結(jié)果合并。這個形式可以最大限度的減少資源爭用,而且減少潛在的死鎖和當并行線程試圖更新相同的內(nèi)存位置時所發(fā)生的數(shù)據(jù)不一致的問題。
            使用這個形式?jīng)]有那么復雜,但是需要很乏味的為每一個使用進行手動編碼。為了簡化形式使用,Visual C++ 2010 Beta 1 添加了combinable模版類型。這個模版參數(shù)傳遞到combinable是每個任務將要操作的對象類型。這個類型必須有一個默認的構(gòu)造器和一個拷貝 構(gòu)造器。通過使用local方法,每個任務訪問它自己的combinable管理資源的拷貝。 當所有任務結(jié)束后,通過使用combine 或是 combine_each方法,你可以將所有結(jié)果合并到一個結(jié)果集中。
            以下的代碼用三個獨立的任務添加一些元素給一個矢量,然后用兩個合并的方法將結(jié)果合并成一個矢量。
            //declare a combinable vector of integers
            combinable< vector< int>> v;
            //add an element to the vector using three separate tasks
            parallel_invoke(
            [&]{ v.local().push_back(1); },
            [&]{ v.local().push_back(2); },
            [&]{ v.local().push_back(3); }
            );
            //merge the task-local copies using combine_each
            vector< int> result1;
            v.combine_each(
            [&](vector< int>& local)
            {
            result1.insert(result1.end(),
            local.begin(), local.end());
            }
            );
            //merge the task-local copies using combine
            vector< int> result2 = v.combine(
            [](vector< int> left, vector< int> right)->vector< int>{
            left.insert(left.end(), right.begin(), right.end());
            return left;
            });
            要注意的是在最后一行的代碼語句中的lambda表達式的明確返回類型聲明的使用。在lambda表達式中的兩個語句阻止編譯器正確推斷返回類型,所以需要手動聲明。
            也可以為沒有默認構(gòu)造器(或是在很多情況下默認構(gòu)造器的使用是不合適的)的類型使用combinable,通過使用combinable構(gòu)造 器,它是采用了一個發(fā)生器功能創(chuàng)建了一些模版參數(shù)類型的對象。上面代碼的前面幾行是使用超載發(fā)生器構(gòu)造器而重新編寫的。在這種情況下,發(fā)生器功能返回已經(jīng) 包含一個元素的矢量。
            //declare a combinable vector of integers
            inable< vector< int>> v([]{return vector< int>(1, 0);});
            同步
            Combinable的使用取決于不需要作用在其他任務上的結(jié)果的任務。在多重任務的情況下需要分享一個對象,你必須使用更傳統(tǒng)的同步策略。 PLL本身帶有三個同步原語——critical_section, reader_writer_lock 和 event。critical_section鎖住內(nèi)存位置防止沒有鎖的所有任務的訪問。對于內(nèi)存位置將有很多同時讀取者和少數(shù)編寫者,更優(yōu)化的 reader_writer_lock是可用的,允許多重讀取者獲取鎖并同時訪問內(nèi)存位置。最后的原語是event,用于在任務和線程之間發(fā)信號。
            同步原語在concrt.h標題文件(是PPL的基本標題文件,包含在ppl.h中)中被定義。在concrt.h中定義的大多數(shù)類型的目標是 圖書館作者,而不是應用程序的開發(fā)者,但是任何對深層并行開發(fā)感興趣的人都可以自由的調(diào)查和使用恰當?shù)膩碜员┞对谕獾念愋偷墓δ堋?BR>    critical_section類型的API是非常簡單的;你使用一個blocking lock方法來獲取這個鎖,non-blocking try_lock會試圖去獲取這個鎖,如果它可用的話,而且unlock會釋放一個鎖住的critical_section。
            reader_writer_lock是有一點點的復雜。它添加了兩個方法,lock_read 和try_lock_read,可以支持獲取一個reader lock。Unlock方法和critical_section是一樣的,而且將釋放恰當?shù)幕阪i類型的鎖。
            最后的同步原語是event,這是手動復位事件(即:事件保持設(shè)置直到用外部代碼進行手動復位)。代碼可以通過調(diào)用實例wait方法(也是支持 一個可選的timeout值),等待一個單一事件被設(shè)置。當沒有timeout被定義的時候,等待的時間是無限的。你可以等待多重事件,通過使用靜態(tài) wait_for_multiple,它接受C-style的event pointers。wait_for_multiple方法等待一個單一事件或是所有的事件傳遞到方法調(diào)用。以下的代碼等待這兩個事件被設(shè)置:
            event* events[2];
            events[0] = new event();
            events[1] = new event();
            parallel_invoke(
            [&]{ events[0]->set(); },
            [&]{ events[1]->set(); }
            );
            bool waitForAllEvents = true;
            event::wait_for_multiple(events, 2, waitForAllEvents);
            當同時執(zhí)行很多任務的時候,處理狀態(tài)管理是非常艱巨的工作。PPL提供對狀態(tài)管理的一種形式的支持,就是每個線程在本地版本的分享對象上進行操 作,在程序結(jié)束的時候?qū)⑦@些結(jié)果合并起來。對于分離狀態(tài)管理的情況是不恰當?shù)模琍PL以critical_section, reader_writer_lock 和 event的形式提供傳統(tǒng)的同步原語。