并行计算框架的Java实现--系列三 - JAVA

优化锁，之前的锁是采用一个static的Object实现的，这要就会有一个问题，如果我创建了多个Executer，那么所有Job都会持有一把锁，既影响性能，也容易出现死锁的情况。所以，改成每个Executer持有一把锁。
Executer代码如下：

Java代码
public class Executer {
//计算已经派发的任务数(条件谓词)
public static int THREAD_COUNT = 0;
//存储任务的执行结果
private List> futres = new ArrayList>();
//条件队列锁
public final Object lock = new Object();
//线程池
private ExecutorService pool = null;
public Executer() {
this(1);
}
public Executer(int threadPoolSize) {
pool = Executors.newFixedThreadPool(threadPoolSize);
}
/**
* 任务派发
* @param job
*/
public void fork(Job job){
//设置同步锁
job.setLock(lock);
//将任务派发给线程池去执行
futres.add(pool.submit(job));
//增加线程数
synchronized (lock) {
THREAD_COUNT++;
}
}
/**
* 统计任务结果
*/
public List