CountDownLatch是Jdk5包Concurrent下很实用的工具类之一,主要用来实现多个执行线程的排序,下面例子通过三种方式实现同一功能(本例子JDK5下通过)
package regbin.exa.thread.concurrent;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class CountDownLatchTest {
public void CountDownLatchExa() throws InterruptedException {
final CountDownLatch countDownBegin = new CountDownLatch(1);
final CountDownLatch countDownEnd = new CountDownLatch(2);
Thread threadA = new Thread() {
@Override
public void run() {
try {
countDownBegin.await();
System.out.println("threadA");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
countDownEnd.countDown();
}
}
};
Thread threadB = new Thread() {
@Override
public void run() {
try {
countDownBegin.await();
System.out.println("threadB");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
countDownEnd.countDown();
}
}
};
System.out.println("CountDownLatchExa-X");
threadA.start();
threadB.start();
countDownBegin.countDown();
countDownEnd.await();
System.out.println("CountDownLatchExa-Y");
}
public void waitNotifyExa() throws InterruptedException {
final Object object = new Object();
Thread threadA = new Thread() {
@Override
public void run() {
try {
synchronized (object) {
object.wait();
}
System.out.println("threadA");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
Thread threadB = new Thread() {
@Override
public void run() {
try {
synchronized (object) {
object.wait();
}
System.out.println("threadB");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
};
System.out.println("waitNotifyExa-X");
threadA.start();
threadB.start();
Thread.sleep(2000);//保证通知动作在线程启动之后发出
synchronized (object) {
object.notifyAll();
}
System.out.println("waitNotifyExa-Y");
}
public void CurrentLockExa() throws InterruptedException {
final Lock lock = new ReentrantLock();
final Condition object = lock.newCondition();
Thread threadA = new Thread() {
@Override
public void run() {
lock.lock();
try {
object.await();
System.out.println("threadA");
} catch (InterruptedException e) {
} finally {
lock.unlock();
}
}
};
Thread threadB = new Thread() {
@Override
public void run() {
lock.lock();
try {
object.await();
System.out.println("threadB");
} catch (InterruptedException e) {
} finally {
lock.unlock();
}
}
};
System.out.println("CurrentLockExa-X");
threadA.start();
threadB.start();
Thread.sleep(2000);//保证通知动作在线程启动之后发出
lock.lock();
try {
object.signalAll();
} finally {
lock.unlock();
}
System.out.println("CurrentLockExa-Y");
}
public static void main(String[] args) throws InterruptedException {
CountDownLatchTest test = new CountDownLatchTest();
test.CountDownLatchExa();
test.waitNotifyExa();
test.CurrentLockExa();
}
}
分享到:
相关推荐
本文将详细介绍如何利用MyBatis结合多线程和CountDownLatch闭锁来实现数据的批量插入。 首先,我们来看`mybatis批处理`。MyBatis的批处理功能允许我们在一次数据库连接中执行多条SQL语句,从而减少了数据库连接的...
在Java多线程编程中,CountDownLatch是一个非常重要的同步工具类,它可以帮助我们协调多个线程之间的交互。本文将深入探讨CountDownLatch的工作原理、使用场景以及相关源码分析。 CountDownLatch是一个计数器,初始...
在多线程编程中,确保一组操作按照特定的顺序或者所有操作都完成后再进行下一步是常见的需求。Java 提供了多种工具来实现这样的同步机制,其中之一便是 `CountDownLatch` 类。`CountDownLatch` 是一个计数器,可以...
JAVA多线程CountDownLatch使用详解 JAVA多线程CountDownLatch是JAVA多线程编程中的一种同步工具,主要用来让某个线程等待其他线程执行完毕后再继续执行。下面我们将详细介绍JAVA多线程CountDownLatch的使用和原理。...
Java 使用 CountDownLatch 等待多线程全部执行完成 CountDownLatch 是 Java 中的一个同步工具类,允许一个或多个线程等待其他线程完成操作。它的应用场景非常广泛,例如在处理大量数据时,可以使用多线程的方式处理...
"CountDownLatch" 和 "Thread" 是Java编程语言中实现多线程并行执行的关键工具,它们有助于提高程序的运行效率和响应速度。 **多线程并行执行** 多线程并行执行是指在同一个程序中同时运行多个线程,每个线程负责...
在Java多线程编程中,CountDownLatch是一种常用的同步工具,用于协调多个线程之间的协作,确保它们按照特定的顺序执行或者等待所有线程完成特定任务后再继续执行。这个类是java.util.concurrent包的一部分,提供了...
《JAVA多线程教学演示系统》是一篇深入探讨JAVA多线程编程的论文,它针对教育领域中的教学需求,提供了一种生动、直观的演示方式,帮助学生更好地理解和掌握多线程技术。这篇论文的核心内容可能包括以下几个方面: ...
如何使用CountDownLatch同步java多线程 CountDownLatch 是 Java 并发编程中的一种常用工具,用于控制多个线程的并发执行。它可以实现多个线程之间的同步操作,使得线程之间可以协调工作,避免了线程之间的互相干扰...
在IT行业中,多线程是Java编程中一个重要的高级特性,尤其对于开发高效能和响应迅速的应用至关重要。这个“多线程终极案例程序”旨在帮助Java开发者深化对多线程的理解,通过一个具体的“多兵种联合攻击防御塔”游戏...
- **CountDownLatch**:允许一个线程等待其他线程完成操作,常用于多线程并发测试。 - **CyclicBarrier**:允许多个线程等待直到达到某个屏障点再一起继续执行。 - **Semaphore**:信号量,控制同时访问特定资源...
线程池管理和多线程上传是并发编程中的一个重要实践,特别是在大数据传输和网络服务中。在Java等编程语言中,线程池通过有效地管理和复用线程资源,避免了频繁创建和销毁线程带来的开销,提升了系统性能。下面将详细...
《汪文君JAVA多线程编程实战》是一本专注于Java多线程编程的实战教程,由知名讲师汪文君倾力打造。这本书旨在帮助Java开发者深入理解和熟练掌握多线程编程技术,提升软件开发的效率和质量。在Java平台中,多线程是...
9. **并发工具类**:`CountDownLatch`、`CyclicBarrier`和`Semaphore`等并发工具类可以帮助控制线程的启动和同步,提高多线程操作的协调性。 10. **安全性**:在多线程环境下,文件操作需注意文件锁,避免同一时刻...
- **CountDownLatch**:常用于多线程间的同步,计数器从正整数开始,每当一个线程完成任务,计数器减一,当计数器为零时,所有等待的线程将被释放。 - **CyclicBarrier**:允许一组线程等待彼此到达某个屏障点,...
本项目“poi多线程大数据导出excel文件”提供了一个解决方案,利用多线程来提高Excel的大数据导出效率。 Apache POI 3.1版本是较早的版本,而项目中使用了更新的4.1版本,这意味着它可能利用了更多优化和新特性。在...
Java中CountDownLatch进行多线程同步详解及实例代码 CountDownLatch是Java中的一种多线程同步辅助类,主要用来同步多个任务的执行。它允许一个或多个线程等待,直到一组正在其他线程中执行的操作完成。下面是对...
Java多线程与并发编程是Java开发中至关重要的一部分,它涉及到如何高效地利用CPU资源,以实现程序的并行执行。在操作系统层面,多任务和多进程是通过分配不同的内存空间来实现的,而线程则共享同一进程的内存,这...
在编程领域,多线程是实现并发执行任务的关键技术,特别是在服务器端开发和高并发应用中,多线程能够充分利用CPU资源,提高程序的运行效率。这个名为"多线程demo程序-轻松掌握多线程技术"的项目,旨在帮助开发者理解...
在IT领域,多线程和高并发是两个关键概念,特别是在Java编程中,它们对于构建高效、可扩展的系统至关重要。下面将详细解释这两个概念及其在Java中的实现和应用。 多线程是指在一个应用程序中同时运行多个独立的执行...