并發(fā)編程中級篇二----并行設(shè)計模式----Master-Wroker模式

RebeccaZhong 發(fā)布于2019-08-16 10:46 / 3546人閱讀

摘要：模式是常用的并行計算模式，它的核心思想是系統(tǒng)是由兩類進(jìn)程協(xié)助工作。負(fù)責(zé)接收和分配任務(wù)，負(fù)責(zé)處理子任務(wù)。當(dāng)各個子進(jìn)程處理完成后，會返回結(jié)果給，由做歸納和總結(jié)。其好處是能將一個大任務(wù)分解成若干個小任務(wù)，并行執(zhí)行，從而提高系統(tǒng)的吞吐量。

Master-worker模式是常用的并行計算模式，它的核心思想是系統(tǒng)是由兩類進(jìn)程協(xié)助工作。Master負(fù)責(zé)接收和分配任務(wù)，worker負(fù)責(zé)處理子任務(wù)。當(dāng)各個worker子進(jìn)程處理完成后，會返回結(jié)果給master，由master做歸納和總結(jié)。其好處是能將一個大任務(wù)分解成若干個小任務(wù)，并行執(zhí)行，從而提高系統(tǒng)的吞吐量。

1.定義一個要執(zhí)行的任務(wù)類

    public class Task{
        
        private int id;
        
        private int price;
        
        //getter/setter()省略
    }

2.定義Master負(fù)責(zé)收發(fā)任務(wù)

    //注意worker線程的數(shù)量 根據(jù)機(jī)器的性能來添加
    //Runtime.getRuntime().availableProcessors()
    public class Master{
        
        //1.定義一個盛放任務(wù)的容器
        private ConcurrentLinkedQueue workQueue = 
        new ConcurrentLinkedQueue();
                
        //2.需要一個盛放worker的集合
        private HashMap workers = 
        new HashMap();
        
        //3.需要一個盛放每一個worker執(zhí)行任務(wù)的結(jié)果集合
        private ConcurrentHashMap resultMap = 
        new ConcurrentHashMap();
        
        //4.定義一個構(gòu)造方法
        public Master(Worker worker, int workCount){
            worker.setWorkQueue(this.workQueue);
            worker.setResultMap(this.resultMap);
            
            for(int i = 0; i < workerCount; i ++){
                this.workers.put(Integer.toString(i), new Thread(worker));
            }
        }
        
        //5需要一個執(zhí)行提交任務(wù)的方法
        public void submit（Task task){
            this.workQueue.add(task);
        }
        
        //6需要一個執(zhí)行任務(wù)的方法 啟動所有的worker方法去執(zhí)行任務(wù)
        public void execute(){
            for(Map.Entry me : workers.entrySet()){
                me.getValue().start();
            }
        }
        
        //7判斷運(yùn)行是否結(jié)束的方法
        public boolean isComplete(){
            for(Map.Entry me : workers.entrySet()){
                if(me.getValue().getState() != Thread.State.TERMINATED){
                    return false;
                }
            }        
            return true;
        }
        
        //8 計算結(jié)果方法
        public int getResult() {
            int priceResult = 0;
            for(Map.Entry me : resultMap.entrySet()){
                priceResult += (Integer)me.getValue();
            }
            return priceResult;
        }
    }

3.定義一個worker處理子任務(wù)

    public class Worker implements Runnable{
        
        private ConcurrentLinkedQueue workQueue;
        private ConcurrentHashMap resultMap;
        
        public void setWorkQueue(ConcurrentLinkedQueue workQueue) {
            this.workQueue = workQueue;
        }
    
        public void setResultMap(ConcurrentHashMap resultMap) {
            this.resultMap = resultMap;
        }
        
        public void run() {
            while(true){
                Task input = this.workQueue.poll();
                if(input == null) break;
                Object output = handle(input);
                this.resultMap.put(Integer.toString(input.getId()), output);
            }
        }
    
        private Object handle(Task input) {
            Object output = null;
            try {
                //處理任務(wù)的耗時。。 比如說進(jìn)行操作數(shù)據(jù)庫。。。
                Thread.sleep(500);
                output = input.getPrice();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return output;
        }
    }

4.定義一個測試類

    public class Main{
    
         public static void main(String[] args) {
            
            Master master = new Master();
            
            Random r = new Random();
            for(int i = 1;i <= 100;i++){
                Task t = new Task();
                t.setId(i);
                t.setPrice(r.nextInt(1000));
                master.submit(t);
            }
            master.execute();
            long start = System.currentTimeMills();
            
            while(true){
                if(maste.isComplete()){
                    long end = System.currentTimeMills();
                    int priceResult = master.getResult();
                    System.out.println("最終結(jié)果：" + priceResult + 
                    ", 執(zhí)行時間：" + end);
                    break;
                }
            }        
         }
    }

結(jié)果如下

GPU云服務(wù)器云服務(wù)器 java設(shè)計模式并發(fā) 模式編程 python編程模式 bs模式編程語言

文章版權(quán)歸作者所有，未經(jīng)允許請勿轉(zhuǎn)載,若此文章存在違規(guī)行為，您可以聯(lián)系管理員刪除。

轉(zhuǎn)載請注明本文地址：http://systransis.cn/yun/70413.html

發(fā)表評論

登陸后可評論

0條評論

RebeccaZhong

男|高級講師

我要關(guān)注我要私信

TA的文章

3.Java中JVM, JRE和JDK的關(guān)系是什么？

閱讀 3272·2021-11-15 11:37
寶塔面板安裝SmokePing – 一款監(jiān)控網(wǎng)絡(luò)狀態(tài)和穩(wěn)定性的開源軟件

閱讀 1085·2021-11-02 14:45
RAKsmart九月秒殺服務(wù)器$30/月起,洛杉磯/圣何塞/香港/日本站群特價,全場VPS五折

閱讀 3905·2021-09-04 16:48
css可變色圖標(biāo)及原理分析

閱讀 3582·2019-08-30 15:55
Ant Design Pro v4 is Here

閱讀 757·2019-08-23 17:53
prototype原型

閱讀 1000·2019-08-23 17:03
知乎視頻播放器開源了~

閱讀 2032·2019-08-23 16:43
關(guān)于require.context的嘗試

閱讀 2191·2019-08-23 16:22

成人国产在线小视频_日韩寡妇人妻调教在线播放_色成人www永久在线观看_2018国产精品久久_亚洲欧美高清在线30p_亚洲少妇综合一区_黄色在线播放国产_亚洲另类技巧小说校园_国产主播xx日韩_a级毛片在线免费

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

并發(fā)編程中級篇二----并行設(shè)計模式----Master-Wroker模式

相關(guān)文章

并發(fā)編程中級篇二----并行設(shè)計模式----Future模式

并發(fā)編程中級篇三----并行設(shè)計模式----生產(chǎn)者-消費(fèi)者模式

學(xué)習(xí)Java必讀的10本書籍

你和阿里資深架構(gòu)師之間，差的不僅僅是年齡（進(jìn)階必看）

**2021年10月6日軟考中級筆記---軟件設(shè)計師（B站視頻筆記）**

發(fā)表評論

0條評論

RebeccaZhong

男|高級講師

TA的文章

3.Java中JVM, JRE和JDK的關(guān)系是什么？

寶塔面板安裝SmokePing – 一款監(jiān)控網(wǎng)絡(luò)狀態(tài)和穩(wěn)定性的開源軟件

RAKsmart九月秒殺服務(wù)器$30/月起,洛杉磯/圣何塞/香港/日本站群特價,全場VPS五折

css可變色圖標(biāo)及原理分析

Ant Design Pro v4 is Here

prototype原型

知乎視頻播放器開源了~

關(guān)于require.context的嘗試

最新活動

資訊專欄INFORMATION COLUMN

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！

并發(fā)編程中級篇二----并行設(shè)計模式----Master-Wroker模式

相關(guān)文章

發(fā)表評論

0條評論

男|高級講師

TA的文章

最新活動

上云采購季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺、長期優(yōu)惠，快來選購！