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