java并发编程之cyclicbarrier

import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class  implements Runnable {
	private static ConcurrentHashMap<String, Integer> map = new ConcurrentHashMap<String, Integer>();
    private static CyclicBarrier barrier;
	public static void main(String[] args) throws Exception {
		    barrier = new CyclicBarrier(5, new Runnable() {
			
			
			public void run() {
				System.out.println("所有得分得到！");
				int result = 0;
				for (String key : map.keySet()) {
					result += map.get(key);
				}
				System.out.println("平均值为：" + (result/5));
			}
		});

		ExecutorService es = Executors.newCachedThreadPool();
		for (int i = 0; i < 5; i++) {
			es.execute(new Shit());
		}
	}

	
	public void run() {
		try {
			int score = new Random().nextInt(100);
			map.put("科目" + Thread.currentThread().getName() , score);
			System.out.println("科目" +  Thread.currentThread().getName() + "已获得得分: " + score);
			Thread.sleep(1000);
			barrier.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (BrokenBarrierException e) {
			e.printStackTrace();
		}
	}
}