package com.msj.sync.masterworker;

import java.util.concurrent.ConcurrentHashMap;

import java.util.concurrent.ConcurrentLinkedQueue;

/**

* @author Vincent.M mengshaojie@188.com

* @date 2017/3/15 下午3:25

* @copyright ©2017 孟少杰 All Rights Reserved

* @desc Master-Worker模式 Worker

*/

public class Worker implements Runnable {

private ConcurrentLinkedQueue<Task> workQueue;

private ConcurrentHashMap<String, Object> resultMap;

public void setWorkQueue(ConcurrentLinkedQueue<Task> workQueue) {

this.workQueue = workQueue;

}

public void setResultMap(ConcurrentHashMap<String, Object> resultMap) {

this.resultMap = resultMap;

}

@Override

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);

}

}

/**

* 最好父方法不写具体实现，写个子类来实现，例如创建个MyWorker，重写handle

* @param input

* @return

*/

private Object handle(Task input) {

Object output = null;

try {

//处理任务的耗时。。 比如说进行操作数据库。。。

Thread.sleep(500);

output = input.getPrice();

} catch (InterruptedException e) {

e.printStackTrace();

}

return output;

}

}