原先多线程并发编程的学习笔记和代码整理一下贴上来。
---------------------------------
倒计数锁CountDownLatch
根据JDK文档中的描述:
在完成一组正在其他线程中执行的操作之前,它允许一个或多个线程一直等待。
这里给出2个例子如下。
首先定义一个工作线程:
class WorkerThread implements Runnable { private final CountDownLatch startSignal; private final CountDownLatch doneSignal; public WorkerThread(CountDownLatch startSignal,CountDownLatch doneSignal) { this.startSignal = startSignal; this.doneSignal = doneSignal; } public void run() { try{ startSignal.await(); doWork(); doneSignal.countDown(); }catch(InterruptedException ex){ ex.printStackTrace(); } } public void doWork() { System.out.println("do work ..."); } }
这个工作任务中定义了2个倒计数锁,一个开始倒计数锁,一个完成倒计数锁。
简要介绍一下倒计数锁的2个常用方法await和countDown:
(1)await:使当前线程在锁存器倒计数至零之前一直等待,除非线程被中断或超出了指定的等待时间.
(2)countDown:递减锁存器的计数。
如果当前计数大于0,则将计数减少。
如果新的计数为0,出于线程调度目的,将重新启用所有的等待线程。
如果当前计数等于0,则不发生任何操作。
因此,上面的线程执行时,先要等待开始倒计数锁为0才会执行,然后执行完,就将结束倒计数锁的值减一,直到所有任务执行完。
使用方法:
CountDownLatch startSignal = new CountDownLatch(1);//任务开始锁存器 CountDownLatch doneSignal = new CountDownLatch(N);//任务结束锁存器 for(int i=0;i<N;++i){ new Thread(new WorkerThread(startSignal,doneSignal)).start(); } System.out.println("before all worker thread run..."); startSignal.countDown(); doneSignal.await(); System.out.println("all work done...");
首先,任务开始锁存器等待全部线程创建完成,然后countDown,这时开始执行各自的线程,任务结束锁存器会一直等待所有线程执行完,每个线程执行完之后也会countDown,直到任务结束锁存器为0时,才会继续
执行后面的程序。
另外一个例子,使用到了线程池,并且不需要等所有线程创建完后再开始执行,其实差不多:
class WorkerRunnable implements Runnable { private final CountDownLatch doneSignal; private final int i; public WorkerRunnable(CountDownLatch doneSignal,int i) { this.doneSignal = doneSignal; this.i = i; } public void run() { try { doWork(i); doneSignal.countDown(); } catch (Exception ex) { ex.printStackTrace(); } } protected void doWork(int i) { System.out.println("do work:"+i); } }
启动任务:
CountDownLatch doneSignal = new CountDownLatch(N); Executor e = Executors.newCachedThreadPool(); for(int i=0; i<N; ++i) e.execute(new WorkerRunnable(doneSignal,i)); doneSignal.await(); System.out.println("do work end...");
使用倒计数锁存器时,需要注意计数值是在锁存器初始化时指定的,且不可以修改。
相关推荐
│ 高并发编程第一阶段30讲、如何实现一个自己的显式锁Lock精讲下(让锁具备超时功能).mp4 │ 高并发编程第一阶段31讲、如何给你的应用程序注入钩子程序,Linux下演示.mp4 │ 高并发编程第一阶段32讲、如何捕获...
并发编程之CountDownLatch
java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四个...
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf
│ 高并发编程第一阶段30讲、如何实现一个自己的显式锁Lock精讲下(让锁具备超时功能).mp4 │ 高并发编程第一阶段31讲、如何给你的应用程序注入钩子程序,Linux下演示.mp4 │ 高并发编程第一阶段32讲、如何捕获...
龙果 java并发编程原理实战 第2节理解多线程与并发的之间的联系与区别 [免费观看] 00:11:59分钟 | 第3节解析多线程与多进程的联系以及上下文切换所导致资源浪费问题 [免费观看] 00:13:03分钟 | 第4节学习并发的四...
并发工具类CountDownLatch详解.mp4 并发工具类CyclicBarrier 详解.mp4 并发工具类Semaphore详解.mp4 并发工具类Exchanger详解.mp4 CountDownLatch,CyclicBarrier,Semaphore源码解析.mp4 提前完成任务之FutureTask...
主要介绍了Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解的相关资料,需要的朋友可以参考下
java并发编程中CountDownLatch和CyclicBarrier的使用.pdf
Java并发编程基础主要包括以下几个核心方面: ...并发工具类:掌握Java并发包java.util.concurrent中提供的各种工具类,如CountDownLatch、CyclicBarrier、Semaphore等,它们简化了并发编程的复杂性。
第37节并发工具类CountDownLatch详解00:22:04分钟 | 第38节并发工具类CyclicBarrier 详解00:11:52分钟 | 第39节并发工具类Semaphore详解00:17:27分钟 | 第40节并发工具类Exchanger详解00:13:47分钟 | 第41节...
并发编程的一些小示例 1.等待通知的几种方式,包括Object的wait/notify,Condition的await/signal 2. CountDownLatch,统一控制多线程开始和结束 3.原子操作,AtomicXXX 4.线程池
1、本资源包含并发编程基础知识的使用案例,包括:线程创建、Synchronized和Reentrantlock锁的使用、线程安全问题演示、Condition的应用、CountDownLatch的应用、Cyclicbarrier的应用、Semaphore的应用、线程池的...
7、并发工具类CountDownLatch 、CyclicBarrier和Semaphore底层实现原理 8、线程池原理和如何使用线程池 9、ThreadLocal 为什么会内存泄漏 10、Volatile底层实现原理 11、AQS源码分析 12、CAS原理分析和使用场景 13、...
二、闭锁CountDownLatch 28 1、应用场景 28 2、CyclicBarrier 28 3、Semaphore 29 4、Callable、Future和FutureTask 30 5、原子操作CAS (compare atomic swap) 32 三、显式锁和AQS 34 1、AQS定义两种资源共享方式: ...
第37节并发工具类CountDownLatch详解00:22:04分钟 | 第38节并发工具类CyclicBarrier 详解00:11:52分钟 | 第39节并发工具类Semaphore详解00:17:27分钟 | 第40节并发工具类Exchanger详解00:13:47分钟 | 第41节...
Java并发编程实战 本书深入浅出地介绍了Java线程和并发,是一本完美的Java并发参考手册。书中从并发性和线程安全性的基本概念出发,介绍了如何使用类库提供的基本并发构建块,用于避免并发危险、构造线程安全的类及...
6)用 Java 编程一个会导致死锁的程序,你将怎么解决? 7) 什么是原子操作,Java 中的原子操作是什么? 8) Java 中的 volatile 关键是什么作用?怎样使用它?在 Java 中它跟 synchronized 方法有什么不同? 9) 什么...