CyclicBarrier处理控制多线程顺序

一直苦于无法控制多线程的处理顺序，最近看到java提供了很好的工具，所以抓过来学习下。但是看了一通注释还有网上的一堆解释，看的头晕。还是写一个测试代码来理解好了。

示例代码实现了，多个线程处理list加总和的问题。

主要有两点需要注意:

1，通过CyclicBarrier来控制多线程处理流程

2，通过synchronized来同步汇总总和

package com.thread;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.CyclicBarrier;

/**
* 模拟多个线程来处理list的数据加和，并最后打出结果
* @author owen.huang
*
*/

class SumList implements Runnable{
private List<Integer> subList;
private CyclicBarrier barrier;
private Integer subSum = 0;
public static Long allSum = 0l;
private static Object obj = new Object();

public Integer getSubSum() {
return subSum;
}

public SumList(List<Integer> subList, CyclicBarrier barrier){
this.subList = subList;
this.barrier = barrier;
}

public void run() {
for(int i=0;i<subList.size();i++){
subSum = subSum + subList.get(i);
}

synchronized(obj){
allSum = allSum + subSum;
}

try {
barrier.await();//要求计算完毕，等待其它线程
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
}
}

public class TestCyclicbarrier {
public static void main(String[] args){
int threadCounts = 10;//线程数
int num = 100000;

//之所以加1，是为了控制主线程，让它等待知道所有线程走完
CyclicBarrier barrier = new CyclicBarrier(threadCounts+1);

List<Integer> list = new ArrayList<Integer>();
for(int i=0;i<num;i++){
list.add(i);
}

int intval = num/threadCounts;

for(int i=0;i<threadCounts;i++){
List<Integer> subList = list.subList(intval*i, intval*(i+1));
SumList s = new SumList(subList,barrier);
new Thread(s).start();
}
try {
barrier.await();//要求主线程等待其它线程运行结束
} catch (InterruptedException e) {
e.printStackTrace();
} catch (BrokenBarrierException e) {
e.printStackTrace();
}
System.out.println(SumList.allSum);
}
}