`
kobe学java
  • 浏览: 257849 次
  • 性别: Icon_minigender_1
  • 来自: 苏州
社区版块
存档分类
最新评论

浅析Java中CountDownLatch用法

 
阅读更多

 


CountDownLatch如其所写,是一个倒计数的锁存器,当计数减至0时触发特定的事件。利用这种特性,可以让主线程等待子线程的结束。下面以一个模拟运动员比赛的例子加以说明。

复制代码
1 import java.util.concurrent.CountDownLatch;
2  import java.util.concurrent.Executor;
3  import java.util.concurrent.ExecutorService;
4  import java.util.concurrent.Executors;
5
6  public class CountDownLatchDemo {
7 private static final int PLAYER_AMOUNT = 5;
8 public CountDownLatchDemo() {
9 // TODO Auto-generated constructor stub
10   }
11 /**
12 * @param args
13 */
14 public static void main(String[] args) {
15 // TODO Auto-generated method stub
16 //对于每位运动员,CountDownLatch减1后即结束比赛
17 CountDownLatch begin = new CountDownLatch(1);
18 //对于整个比赛,所有运动员结束后才算结束
19 CountDownLatch end = new CountDownLatch(PLAYER_AMOUNT);
20 Player[] plays = new Player[PLAYER_AMOUNT];
21
22 for(int i=0;i<PLAYER_AMOUNT;i++)
23 plays[i] = new Player(i+1,begin,end);
24
25 //设置特定的线程池,大小为5
26 ExecutorService exe = Executors.newFixedThreadPool(PLAYER_AMOUNT);
27 for(Player p:plays)
28 exe.execute(p); //分配线程
29 System.out.println("Race begins!");
30 begin.countDown();
31 try{
32 end.await(); //等待end状态变为0,即为比赛结束
33 }catch (InterruptedException e) {
34 // TODO: handle exception
35 e.printStackTrace();
36 }finally{
37 System.out.println("Race ends!");
38 }
39 exe.shutdown();
40 }
41 }
复制代码

接下来是Player类

复制代码
1 import java.util.concurrent.CountDownLatch;
2
3
4 public class Player implements Runnable {
5
6 private int id;
7 private CountDownLatch begin;
8 private CountDownLatch end;
9 public Player(int i, CountDownLatch begin, CountDownLatch end) {
10 // TODO Auto-generated constructor stub
11 super();
12 this.id = i;
13 this.begin = begin;
14 this.end = end;
15 }
16
17 @Override
18 public void run() {
19 // TODO Auto-generated method stub
20 try{
21 begin.await(); //等待begin的状态为0
22 Thread.sleep((long)(Math.random()*100)); //随机分配时间,即运动员完成时间
23 System.out.println("Play"+id+" arrived.");
24 }catch (InterruptedException e) {
25 // TODO: handle exception
26 e.printStackTrace();
27 }finally{
28 end.countDown(); //使end状态减1,最终减至0
29 }
30 }
31 }
分享到:
评论

相关推荐

    Java中CountDownLatch用法解析

    在Java并发编程中,`CountDownLatch`是一个非常重要的工具类,它位于`java.util.concurrent`包下,用于协调多个线程间的同步。`CountDownLatch`的主要作用是允许一个或多个线程等待其他线程完成操作。在上述例子中,...

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

    java并发编程中CountDownLatch和CyclicBarrier的使用借鉴 java并发编程中CountDownLatch和CyclicBarrier是两个非常重要的线程控制和调度工具,经常被用于解决多线程程序设计中的线程等待问题。本文将对...

    Java并发包之CountDownLatch用法.docx

    `CountDownLatch`是Java并发包`java.util.concurrent`中的一个重要工具类,用于实现线程间的同步。它基于计数器的概念,初始化时设置一个非负的计数值,然后通过调用`countDown()`方法来递减这个计数器。主线程或...

    Java中CountDownLatch进行多线程同步详解及实例代码

    Java中CountDownLatch进行多线程同步详解及实例代码 CountDownLatch是Java中的一种多线程同步辅助类,主要用来同步多个任务的执行。它允许一个或多个线程等待,直到一组正在其他线程中执行的操作完成。下面是对...

    java使用CountDownLatch等待多线程全部执行完成

    Java 使用 CountDownLatch 等待多线程全部执行完成 CountDownLatch 是 Java 中的一个同步工具类,允许一个或多个线程等待其他线程完成操作。它的应用场景非常广泛,例如在处理大量数据时,可以使用多线程的方式处理...

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

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

    Java concurrency之CountDownLatch原理和示例_动力节点Java学院整理

    下面我们将深入探讨CountDownLatch的原理、使用方法以及与CyclicBarrier的区别。 首先,CountDownLatch的构造函数接受一个整数参数`count`,这个值表示计数器的初始值。当这个计数器归零时,所有等待在`await()`...

    CountDownLatch学习用法

    CountDownLatch是Java并发编程中一个重要的工具类,它属于java.util.concurrent包下的一个同步辅助类。这个类的设计目的是允许一个线程等待其他多个线程完成操作,然后再继续执行。CountDownLatch通常用于多线程协作...

    Java中的CountDownLatch类最全讲义

    CountDownLatch的基本用法 2.1 创建CountDownLatch对象 2.2 await()方法 2.3 countDown()方法 实现多线程任务的同步 3.1 场景介绍 3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 4.1 场景介绍 4.2 使用...

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

    在Java并发编程中,CountDownLatch和CyclicBarrier是两种非常重要的同步工具,用于协调多个线程之间的交互。它们都属于java.util.concurrent包下的类,为多线程编程提供了强大的支持。 **CountDownLatch** 是一个...

    java利用CountDownLatch实现并行计算

    在上面的示例代码中,我们创建了一个 ParallelComputing 类,其中包含了一个 calc() 方法,它执行计算任务,并使用 CountDownLatch 来等待所有线程执行完成。calcSum() 方法创建了多个线程,每个线程执行 calc() ...

    CountDownLatch和CyclicBarrier用法实例大全

    在Java并发编程中,CountDownLatch和CyclicBarrier是两种非常重要的同步工具类,它们用于协调多个线程间的协作。这两个工具都是在`java.util.concurrent`包下,是Java并发库的重要组成部分。 **CountDownLatch** ...

    JAVA多线程CountDownLatch使用详解

    JAVA多线程CountDownLatch使用详解 JAVA多线程CountDownLatch是JAVA多线程编程中的一种同步工具,主要用来让某个线程等待其他线程执行完毕后再继续执行。下面我们将详细介绍JAVA多线程CountDownLatch的使用和原理。...

    多线程countDownLatch方法介绍

    在Java多线程编程中,CountDownLatch是一个非常重要的同步工具类,它可以帮助我们协调多个线程之间的交互。本文将深入探讨CountDownLatch的工作原理、使用场景以及相关源码分析。 CountDownLatch是一个计数器,初始...

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

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

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

    在Java并发编程中,`CountDownLatch`是一个同步辅助类,它允许多个线程等待其他线程完成操作。在批量插入数据的场景下,可以创建一个CountDownLatch对象,初始化为线程的数量,每个线程处理完自己的数据后调用`...

    利用 CountDownLatch 类实现线程同步

    1. **初始化异步操作**:在 Activity 或 Fragment 的生命周期方法中,如果需要先执行一系列异步操作(如网络请求、数据库初始化等)再显示界面,可以使用 `CountDownLatch` 来等待这些异步操作完成。 2. **并发测试...

    JAVA高级编程资料

    总结来说,这份"JAVA高级编程资料"涵盖了JAVA开发中的关键知识点,包括多线程的管理与同步、网络编程的基础与优化、文件与流的使用技巧以及集合类的深入理解。这些内容对于任何想在JAVA开发领域深入学习或提升技能的...

    详解Java多线程编程中CountDownLatch阻塞线程的方法

    Java中的CountDownLatch是一种多线程同步工具类,它允许一个或多个线程等待其他线程完成操作。在Java多线程编程中,CountDownLatch扮演着“共享锁”的角色,类似于读写锁中的ReadLock,其核心功能是通过一个计数器来...

    JavaApi中文参考手册.zip

    7. **泛型**:Java 5引入的泛型增强了代码的类型安全性,允许在类、接口和方法中使用类型参数。 8. **注解(Annotation)**:自Java 5开始引入,用于向编译器或JVM提供元数据,如`@Override`、`@Deprecated`、`@ ...

Global site tag (gtag.js) - Google Analytics