对比 使用CyclicBarrier
上次用Barrier方式实现了线程等待一组完成，这次用CountDownLatch来实现
我的理解CountDownLatch 采用的方式是计数器方式，每执行完一个线程，计数器减一，等计数器减到0的时候，之前等待的线程就可以执行了。
和Barrier的例子一样，这次是2个线程等待一组完成，代码如下：
package countdown;
import java.util.Arrays;
import java.util.List;
import java.util.Random;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class Demo {
public static void main(String[] args) {
List<String> students = Arrays.asList("Tom","Bill","Dick","Marry","Lily","Harry");
StudentCalc calc = new StudentCalc();
CountDownLatch cdl= new CountDownLatch(students.size());//算是个计数器吧
ExecutorService exec = Executors.newCachedThreadPool();//用线程池方式执行
exec.execute(new TotalScore(cdl,new StudentCalc("语文")));//汇总任务
exec.execute(new TotalScore(cdl,new StudentCalc("英语")));//汇总任务
students.forEach(x->exec.execute(new StudentScore(cdl,calc,x)));//每个学生的任务
exec.shutdown();//关闭线程池
}
}
class StudentScore implements Runnable{
private StudentCalc studentCalc;
private String studentName;
private CountDownLatch countDownLatch;
public StudentScore( CountDownLatch cdl, StudentCalc studentCalc, String studentName) {
this.countDownLatch=cdl;
this.studentCalc = studentCalc;
this.studentName = studentName;
}
@Override
public void run() {
studentCalc.student(studentName);
countDownLatch.countDown();//计算之后计数器-1
}
}
class TotalScore implements Runnable{
private StudentCalc studentCalc;
private CountDownLatch countDownLatch;
TotalScore(CountDownLatch cdl, StudentCalc studentCalc) {
this.studentCalc = studentCalc;
this.countDownLatch = cdl;
}
@Override
public void run() {
try {
countDownLatch.await();//先等待所有线程完成
} catch (InterruptedException e) {
e.printStackTrace();
}
studentCalc.total();//总成绩 计算
}
}
/**
* 计算类
*/
class StudentCalc {
private String type;
public StudentCalc(String type) {
this.type = type;
}
public StudentCalc() {
}
/**
* 全部成绩计算完成后，调用汇总
*/
public void total(){
System.out.println(type + "全体学生成绩汇总计算");
}
/**
* 计算每个学生自己成绩，为了模拟每个学生计算时间不同，使用Thread.sleep区分
* @param student
*/
public void student(String student){
try {
Thread.sleep(new Random().nextInt(2000));
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("计算" + student + "成绩");
}
}
执行结果如下：
计算Lily成绩 计算Bill成绩 计算Harry成绩 计算Marry成绩 计算Dick成绩 计算Tom成绩 英语全体学生成绩汇总计算 语文全体学生成绩汇总计算