`
TrueBrian
  • 浏览: 8965 次
社区版块
存档分类
最新评论

CountDownLatch的介绍和使用

阅读更多

一、类介绍

 

    java.util.concurrent类CountDownLatch

    public class CountDownLatch extends Object

    一个同步辅助类,在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。给定一个数来初始化CountDownLatch,这个值即需要等待的操作数。当某个线程需要等待一组操作时,通过调用await方法进行阻塞。某个操作完成,通过调用countDown方法使计数器减一。在该计数值到达0之前,调用await()方法的线程会一直等待。之后会释放所有等待的线程,await的后续调用将立即返回。该计数值无法被重置,即只能被初始化一次。

 

二、使用场景

  • 将计数 1 初始化的 CountDownLatch 用作一个简单的开/关锁存器,或入口:在通过调用 countDown() 的线程打开入口前,所有调用 await 的线程都一直在入口处等待;

  • 用 N 初始化的 CountDownLatch 可以使一个线程在 N 个线程完成某项操作之前一直等待,或者使其在某项操作完成 N 次之前一直等待。

 

三、使用实例

    1.等待者和任务者,一群等待者线程等待一群任务者线程完成任务。使用Countdownlatch控制等待者们等待,直到所有的任务者都完成它们的任务后,等待者才能执行。

package concurrent;

import java.util.concurrent.*;
import java.util.*;
import static net.mindview.util.Print.*;

// Performs some portion of a task:
class TaskPortion implements Runnable {
	private static int counter = 0;
	private final int id = counter++;
	private static Random rand = new Random(47);
	private final CountDownLatch latch;

	TaskPortion(CountDownLatch latch) {
		this.latch = latch;
	}

	public void run() {
		try {
			doWork();
			latch.countDown();
		} catch (InterruptedException ex) {
			// Acceptable way to exit
		}
	}

	public void doWork() throws InterruptedException {
		TimeUnit.MILLISECONDS.sleep(rand.nextInt(2000));
		print(this + "completed");
	}

	public String toString() {
		return String.format("%1$-3d ", id);
	}
}

// Waits on the CountDownLatch:
class WaitingTask implements Runnable {
	private static int counter = 0;
	private final int id = counter++;
	private final CountDownLatch latch;

	WaitingTask(CountDownLatch latch) {
		this.latch = latch;
	}

	public void run() {
		try {
			latch.await();
			print("Latch barrier passed for " + this);
		} catch (InterruptedException ex) {
			print(this + " interrupted");
		}
	}

	public String toString() {
		return String.format("WaitingTask %1$-3d ", id);
	}
}

public class CountDownLatchDemo {
	static final int SIZE = 10;

	public static void main(String[] args) throws Exception {
		ExecutorService exec = Executors.newCachedThreadPool();
		// All must share a single CountDownLatch object:
		CountDownLatch latch = new CountDownLatch(SIZE);
		for (int i = 0; i < 5; i++)
			exec.execute(new WaitingTask(latch));
		
		/*创建100个任务线程,共享一个count为100的CountDownLatch,每个线程完成任务后执行countdown将count-1,直到count为0时,
		 * 即所有的线程都完成了任务,等待线程才能执行,因此,CountDownLatch可以很方便的等待一组线程完成任务*/
		for (int i = 0; i < SIZE; i++)
			exec.execute(new TaskPortion(latch));
		print("Launched all tasks");
		exec.shutdown(); // Quit when all tasks complete
	}
} /* (Execute to see output) */// :~

 

    上面的例子中创建了5个等待者线程和10个任务者线程。创建了一个初始值为10的CountdownLatch,5个等待者共享这个CountDownLatch,意思是他们共同等待一些操作,操作的个数为10.在每个操作中调用countDown()。所以10个任务者线程也共享这个CountDownLatch,每个线程完成任务后都调用了countDown,否则等待者们会一直等待。(注意:初始计数值的大小和任务者线程数要相同)

 

输出:

Launched all tasks
7   completed
8   completed
5   completed
9   completed
0   completed
3   completed
6   completed
4   completed
1   completed
2   completed
Latch barrier passed for WaitingTask 0   
Latch barrier passed for WaitingTask 2   
Latch barrier passed for WaitingTask 4   
Latch barrier passed for WaitingTask 1   
Latch barrier passed for WaitingTask 3

 

    2.跑步比赛,所有的Player都必须等待听到枪响声后才能起跑。

package concurrent;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;


class Player implements Runnable{

	private CountDownLatch latch ;
	
	
	public Player(CountDownLatch l) {
		// TODO Auto-generated constructor stub
		this.latch = l;
	}
	
	@Override
	public void run() {
		// TODO Auto-generated method stub
		try {
			latch.await();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(Thread.currentThread().getName() + " start to run!");
	}
	
}

class Guner implements Runnable{
	private CountDownLatch latch ;

	public Guner(CountDownLatch latch) {
		super();
		this.latch = latch;
	}

	@Override
	public void run() {
		// TODO Auto-generated method stub
		for(int i = 0;i < 3;i++){
			System.out.println(3-i);
		}
		System.out.println("Bong!");
		latch.countDown();
	}
	
	
}
public class CountDownLatchTest2 {

	public static void main(String[] args) {
		// TODO Auto-generated method stub
		CountDownLatch latch = new CountDownLatch(1);
		ExecutorService exec = Executors.newCachedThreadPool();
		for(int i = 0;i < 8;i++){
			exec.execute(new Player(latch));
		}
		exec.execute(new Guner(latch));
	}

}

 

输出:

3
2
1
Bong!
pool-1-thread-1 start to run!
pool-1-thread-3 start to run!
pool-1-thread-8 start to run!
pool-1-thread-2 start to run!
pool-1-thread-4 start to run!
pool-1-thread-5 start to run!
pool-1-thread-6 start to run!
pool-1-thread-7 start to run!

 

三、重要方法

await
public void await()
           throws InterruptedException
使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断。
如果当前计数为零,则此方法立即返回。
如果当前计数大于零,则出于线程调度目的,将禁用当前线程,且在发生以下两种情况之一前,该线程将一直处于休眠状态:
由于调用 countDown() 方法,计数到达零;或者
其他某个线程中断当前线程。
如果当前线程:
在进入此方法时已经设置了该线程的中断状态;或者
在等待时被中断,
则抛出 InterruptedException,并且清除当前线程的已中断状态。

抛出:
InterruptedException - 如果当前线程在等待时被中断
​await
public boolean await(long timeout,                     TimeUnit unit)
              throws InterruptedException
使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断或超出了指定的等待时间。
如果当前计数为零,则此方法立刻返回 true 值。
如果当前计数大于零,则出于线程调度目的,将禁用当前线程,且在发生以下三种情况之一前,该线程将一直处于休眠状态:
由于调用 countDown() 方法,计数到达零;或者
其他某个线程中断当前线程;或者
已超出指定的等待时间。
如果计数到达零,则该方法返回 true 值。
如果当前线程:
在进入此方法时已经设置了该线程的中断状态;或者
在等待时被中断,
则抛出 InterruptedException,并且清除当前线程的已中断状态。
如果超出了指定的等待时间,则返回值为 false。如果该时间小于等于零,则此方法根本不会等待。

参数:
timeout - 要等待的最长时间
unit - timeout 参数的时间单位。
返回:
如果计数到达零,则返回 true;如果在计数到达零之前超过了等待时间,则返回 false
抛出:
InterruptedException - 如果当前线程在等待时被中断
countDown
public void countDown()
递减锁存器的计数,如果计数到达零,则释放所有等待的线程。
如果当前计数大于零,则将计数减少。如果新的计数为零,出于线程调度目的,将重新启用所有的等待线程。
如果当前计数等于零,则不发生任何操作。  

分享到:
评论

相关推荐

    java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf

    本文将对CountDownLatch和CyclicBarrier的使用场景和实现进行详细的介绍。 CountDownLatch的应用场景: CountDownLatch是一个非常有用的线程控制工具,它可以使一个线程等待其他线程达到某一目标后进行自己的下...

    多线程countDownLatch方法介绍

    本文将深入探讨CountDownLatch的工作原理、使用场景以及相关源码分析。 CountDownLatch是一个计数器,初始化时设定一个初始值,通常表示一个任务的子任务数量。每个线程完成其工作后会调用`countDown()`方法,...

    mybaits 多线程 实现数据批量插入 (运用CountDownLatch实现闭锁)

    本文将详细介绍如何利用MyBatis结合多线程和CountDownLatch闭锁来实现数据的批量插入。 首先,我们来看`mybatis批处理`。MyBatis的批处理功能允许我们在一次数据库连接中执行多条SQL语句,从而减少了数据库连接的...

    JAVA多线程CountDownLatch使用详解

    下面我们将详细介绍JAVA多线程CountDownLatch的使用和原理。 什么时候用CountDownLatch? 在多线程编程中,我们经常会遇到这样一种情况:某个线程需要等待其他线程执行完毕后再继续执行。例如,在上面的代码中,...

    Java中的CountDownLatch与CyclicBarrier:深入理解与应用实践

    本文将详细介绍CountDownLatch和CyclicBarrier的工作原理、使用场景以及如何在实际项目中应用它们。 CountDownLatch和CyclicBarrier是Java并发编程中两个非常有用的同步工具,它们在不同的场景下有着各自的优势。...

    Java中的CountDownLatch类最全讲义

    3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 4.1 场景介绍 4.2 使用CountDownLatch实现等待 CountDownLatch的其他应用场景 5.1 倒计时计时器 5.2 同时开始任务 5.3 等待多个资源就绪 CountDownLatch与...

    CountDownLatch、Semaphore等4大并发工具类详解

    本文将详细介绍 Java 并发工具类的四大类:CountDownLatch、Semaphore、CyclicBarrier 和 Phaser,及其应用场景和使用方法。 CountDownLatch CountDownLatch 是一个同步的辅助类,允许一个或多个线程,等待其他一...

    SpringBoot CountDownLatch多任务并行处理的实现方法

    SpringBoot ...使用 CountDownLatch 可以实现多任务并行处理,提高系统性能和用户体验。在我们的示例中,我们使用五个任务来模拟统计功能点的计算,但是使用 CountDownLatch 可以轻松地扩展到更多的任务。

    J.U.C-AQS框架同步组件之闭锁CountDownLatch介绍

    在上述的代码示例中,`CountDownLatchExample2`展示了如何使用CountDownLatch和Semaphore结合,来控制并发线程的数目并确保所有线程执行完毕。`countDown()`方法在finally块中调用,以确保无论是否发生异常,计数器...

    java利用CountDownLatch实现并行计算

    Java 利用 CountDownLatch 实现并行计算 ...本文介绍了 CountDownLatch 的使用和示例代码,演示了如何使用 CountDownLatch 实现并行计算。hope 本文能够帮助读者更好地理解并行计算和 CountDownLatch 的使用。

    Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解

    本文将详细介绍这三个辅助类的用法和实例详解。 一、CountDownLatch用法 CountDownLatch类位于java.util.concurrent包下,利用它可以实现类似计数器的功能。它可以让一个线程等待其他线程执行完毕后再执行。...

    JAVA CountDownLatch(倒计时计数器)用法实例

    本文将详细介绍 CountDownLatch 的用法实例,通过示例代码来讲解其使用方法。 CountDownLatch 的主要方法 CountDownLatch 有两个主要方法:countDown() 和 await()。 1. countDown() 方法: public void ...

    JAVA CountDownLatch与thread-join()的区别解析

    JAVA 中的线程同步机制是非常重要的,CountDownLatch 和 thread-join() 是两种常用的线程同步方法,本文将详细介绍它们之间的区别。 首先, thread-join() 方法是Java语言中提供的一种线程同步机制,当一个线程调用...

    java并发编程专题(八)----(JUC)实例讲解CountDownLatch

    本篇文章主要介绍了Java中的CountDownLatch类,作为Java并发编程专题(八)的一部分,通过实例讲解帮助读者理解和学习。下面是文章中的知识点总结: 一、CountDownLatch简介 CountDownLatch是一个同步辅助类,允许...

    java实用编程技术集锦150例(有内容介绍和完整代码)

    - CountDownLatch和CyclicBarrier:协调多个线程间的同步。 这些实例涵盖了Java开发中的诸多重要知识点,每个例子都提供了完整代码,方便读者实践和学习。通过这些实践,你可以加深对Java编程的理解,提升解决实际...

    thread count

    #### 一、CountDownLatch 基础介绍 `CountDownLatch` 可以被视为一种同步辅助工具,它的主要功能是允许一个或多个线程等待其他线程完成某些操作。具体来说,`CountDownLatch` 维护了一个内部计数器(初始值由用户...

    让线程按顺序执行8种方法.doc

    本文将介绍让线程按顺序执行的8种方法,涉及到多线程中许多常用的方法,不止为了知道如何让线程按顺序运行,更是让读者对多线程的使用有更深刻的了解。 一、使用线程的join方法 join()是Thread的方法,作用是调用...

    Java进阶教程,面试大全,包罗万象

    Java进阶教程,面试大全1,可参考以下问题: Semaphore-信号灯机制。 synchronized在静态方法和普通方法的区别。 怎么实现所有线程在等待某个事件的发生...CountDownLatch和CyclicBarrier的用法,以及相互之间的差别。

    Java进阶教程,面试大全

    Java进阶教程,面试大全1,可参考以下问题: Semaphore-信号灯机制。 synchronized在静态方法和普通方法的区别。 怎么实现所有线程在等待某个事件的发生...CountDownLatch和CyclicBarrier的用法,以及相互之间的差别。

Global site tag (gtag.js) - Google Analytics