当前位置: 首页 > 工具软件 > Countdown! > 使用案例 >

CountDownLauch

长孙作人
2023-12-01
@Test
	public void testCountDownLauch(){
		ExecutorService executorService = Executors.newFixedThreadPool(4);
		final CountDownLatch order = new CountDownLatch(1);
		final CountDownLatch answer = new CountDownLatch(4);
		for(int i=0;i<4;i++){
			Runnable runnable = new Runnable() {
				@Override
				public void run() {
					try {
						System.out.println("线程:"+Thread.currentThread().getName()+"等待执行");
						order.await();//等待order执行countDown方法
						System.out.println("线程:"+Thread.currentThread().getName()+"出发");
						Thread.sleep((long) (Math.random() * 10000));
						System.out.println("线程:" + Thread.currentThread().getName() + "执行结束");
					} catch (InterruptedException e) {
						e.printStackTrace();
					}finally {
						answer.countDown();//计数器减一
					}

				}
			};
			executorService.execute(runnable);
		}

		//order执行countDown方法;线程开始执行
		try {
			Thread.sleep((long) (Math.random() * 10000));
			System.out.println("线程执行命令即将发出");
			order.countDown();
			System.out.println("线程执行命令发出");
			answer.await();//等待answer里面的线程执行结束,等待answer执行countDown方法;
			System.out.println("所有线程执行结束");
			System.out.println("主线程执行");
		} catch (InterruptedException e) {
			e.printStackTrace();
		}

		executorService.shutdown();

	}

CountDownLatch和Join用法的区别?

在使用join()中,多个线程只有在执行完毕之后才能被解除阻塞,而在CountDownLatch中,线程可以在任何时候任何位置调用countdown方法减少计数,通过这种方式,我们可以更好地控制线程的解除阻塞,而不是仅仅依赖于连接线程的完成。

如果侵权,联系本人删除

 类似资料:

相关阅读

相关文章

相关问答