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

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

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

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

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

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

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

    //注意worker線程的數(shù)量 根據(jù)機(jī)器的性能來(lái)添加
    //Runtime.getRuntime().availableProcessors()
    public class Master{
        
        //1.定義一個(gè)盛放任務(wù)的容器
        private ConcurrentLinkedQueue workQueue = 
        new ConcurrentLinkedQueue();
                
        //2.需要一個(gè)盛放worker的集合
        private HashMap workers = 
        new HashMap();
        
        //3.需要一個(gè)盛放每一個(gè)worker執(zhí)行任務(wù)的結(jié)果集合
        private ConcurrentHashMap resultMap = 
        new ConcurrentHashMap();
        
        //4.定義一個(gè)構(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需要一個(gè)執(zhí)行提交任務(wù)的方法
        public void submit（Task task){
            this.workQueue.add(task);
        }
        
        //6需要一個(gè)執(zhí)行任務(wù)的方法 啟動(dòng)所有的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 計(jì)算結(jié)果方法
        public int getResult() {
            int priceResult = 0;
            for(Map.Entry me : resultMap.entrySet()){
                priceResult += (Integer)me.getValue();
            }
            return priceResult;
        }
    }

3.定義一個(gè)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ù)的耗時(shí)。。 比如說(shuō)進(jìn)行操作數(shù)據(jù)庫(kù)。。。
                Thread.sleep(500);
                output = input.getPrice();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return output;
        }
    }

4.定義一個(gè)測(cè)試類

    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í)行時(shí)間：" + end);
                    break;
                }
            }        
         }
    }

結(jié)果如下

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

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

轉(zhuǎn)載請(qǐng)注明本文地址：http://m.hztianpu.com/yun/70413.html

發(fā)表評(píng)論

登陸后可評(píng)論

0條評(píng)論

RebeccaZhong

男|高級(jí)講師

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

TA的文章

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

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

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

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

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

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

閱讀 1055·2019-08-23 17:03
知乎視頻播放器開(kāi)源了~

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

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

成人无码视频,亚洲精品久久久久av无码,午夜精品久久久久久毛片,亚洲中文字幕日韩无码

資訊專欄INFORMATION COLUMN

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

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

相關(guān)文章

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

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

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

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

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

發(fā)表評(píng)論

0條評(píng)論

RebeccaZhong

男|高級(jí)講師

TA的文章

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

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

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

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

Ant Design Pro v4 is Here

prototype原型

知乎視頻播放器開(kāi)源了~

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

最新活動(dòng)

資訊專欄INFORMATION COLUMN

上云采購(gòu)季！| 2核2G4M爆款云服務(wù)器低至59元/年，更有多臺(tái)、長(zhǎng)期優(yōu)惠，快來(lái)選購(gòu)！

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

相關(guān)文章

發(fā)表評(píng)論

0條評(píng)論

男|高級(jí)講師

TA的文章

最新活動(dòng)

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