闭锁CountDownLatch和栅栏CyclicBarrier之异同举例

标签：concurrency   闭锁   栅栏   java   

</pre><pre name="code" class="java">class ItemRunnable implements Runnable {
	private CountDownLatch begin, end;
	private List<Integer> sublist;
	
	public ItemRunnable(List<Integer> sublist, CountDownLatch begin,CountDownLatch end) {
		this.sublist = sublist;
		
		this.begin = begin;
		this.end = end;
	}
	
	@Override
	public void run() {
		try {
			begin.await();			
			
			if (sublist != null) {
				for (int i : sublist) {
					System.out.println("线程" + Thread.currentThread().getName() + ", i = " + i);
				}
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		} finally{
			System.out.println(System.currentTimeMillis() + ",线程" + Thread.currentThread().getName() + ",开始执行！");
			end.countDown();
		}
	}
}

public class BatchWithCountDownLatch {
	private static final int MAX = 3;
	
	private static void list(List<Integer> list) {
		if(list == null){
			list = new ArrayList<Integer>();
		}
		
		for(int i = 0 ;i < 1000;i++){
			list.add(i);
		}
	}

	public static void main(String[] args) {
		List<Integer> list = new ArrayList<Integer>();
		list(list);
		
		//把list拆分成多个
		int mod = list.size() % MAX;
		int threadCount = mod == 0 ? list.size() / MAX : list.size() / MAX + 1;
		ExecutorService executors = Executors.newFixedThreadPool(threadCount);
		
		CountDownLatch begin = new CountDownLatch(1); 
		CountDownLatch end = new CountDownLatch(threadCount); 
				
		for(int i = 0; i< threadCount;i++){
			int subsize = (i + 1) * MAX;
			executors.execute(new ItemRunnable(list.subList(i * MAX, subsize > list.size() ? list.size() : subsize),begin,end));
		}
		
		System.out.println("开始 !");
		begin.countDown();
		long startTime = System.currentTimeMillis();
		
		try {
			end.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		} finally {
			System.out.println("线程" + Thread.currentThread().getName() + "," + System.currentTimeMillis() + ", 所有线程已完成，开始进入下一步！");
			System.out.println("花费时间 -> " + (System.currentTimeMillis() - startTime) + " ms");
		}
		
		System.out.println("开始进入第二步操作! ");		
		
		System.out.println("end! ");
	}
}

class ItemRunnable implements Runnable {
    private CyclicBarrier cyclicBarrier;
    private List<Integer> sublist;
    
    public ItemRunnable(List<Integer> sublist, CyclicBarrier cyclicBarrier) {
        this.sublist = sublist;
        this.cyclicBarrier = cyclicBarrier;
    }
    
    @Override
    public void run() {        
        try {
            System.out.println(System.currentTimeMillis() + ",线程" + Thread.currentThread().getName() + ",开始执行！");
            if(sublist != null){
                for(int i : sublist){
                    System.out.println("线程" + Thread.currentThread().getName() + ", i = " + i);
                }
            }

            cyclicBarrier.await();
        } catch (InterruptedException | BrokenBarrierException e) {
            e.printStackTrace();
        }
    }    
}

public class ReplaceCountDownLatch {
    private static final int MAX = 3;
    
    private static void list(List<Integer> list) {
        if(list == null){
            list = new ArrayList<Integer>();
        }
        
        for(int i = 0 ;i < 10;i++){
            list.add(i);
        }
    }
    
    public static void main(String[] args) throws InterruptedException, BrokenBarrierException {
        List<Integer> list = new ArrayList<Integer>();
        list(list);

        //把list拆分成多个
        int mod = list.size() % MAX;
        int threadCount = mod == 0 ? list.size() / MAX : list.size() / MAX + 1;
        ExecutorService executors = Executors.newFixedThreadPool(threadCount);

        final CyclicBarrier cyclicBarrier = new CyclicBarrier(threadCount,new Runnable() {
            @Override
            public void run() {
                //根据jdkdoc里的描述，哪个线程最后运行完，就执行下面的代码。
                System.out.println("线程" + Thread.currentThread().getName() + "," + System.currentTimeMillis() + ", 所有线程已完成，开始进入下一步！");
            }
        });
        
        for(int i = 0; i< threadCount;i++){
            int subsize = (i + 1) * MAX;
            executors.execute(new ItemRunnable(list.subList(i * MAX, subsize > list.size() ? list.size() : subsize),cyclicBarrier));
        }
        
        cyclicBarrier.await();
        executors.shutdown();
        System.out.println("开始进入第二步操作! ");
        
        
        System.out.println("end! ");
    }
}

闭锁CountDownLatch和栅栏CyclicBarrier之异同举例

标签：concurrency   闭锁   栅栏   java   

原文地址：http://blog.csdn.net/gaolu/article/details/46224821