文档章节

Java闭锁_CountDownLatch

秋风醉了
 秋风醉了
发布于 2014/11/18 15:50
字数 1028
阅读 149
收藏 1

Java闭锁_CountDownLatch

闭锁是一种同步工具类,可以延迟线程的进度直到其到达终止状态。闭锁的作用相当于一扇门:在闭锁到达结束状态之前,这扇门一直是关闭的,并且没有任何线程能通过,当到达结束状态时,这扇门会打开并允许所有的线程通过。当闭锁到达结束状态后,将不会在改变状态,因此这扇门将永远保持打开状态。闭锁可以用来确定某些活动直到其他活动都完成后才继续执行,例如:

  1. 确保某个计算在其需要的所有资源都被初始化之后才继续执行。二元闭锁(包括两个状态)可以用来表示“资源R已经被初始化”,而所有需要R的操作都必须在这个闭锁上等待
  2. 确保某个服务在其依赖的所有其他服务都已经启动之后才启动。每个服务都有一个相关的二元闭锁。当启动服务S时,将首先在S 依赖的其他服务的闭锁上 等待,在所有依赖的服务都启动后会释放闭锁S,这样其他依赖S 的服务才能继续执行。
  3. 等待直到某个操作的所有参与者都就绪再继续执行。在这种情况下,当所有玩家都准备就绪时,闭锁将到达结束状态。

CountDownLatch是一种灵活的闭锁实现,可以在上述情况中使用,他可以使一个或多个线程等待一组时间发生。闭锁状态包括一个计数器,该计数器初始化为一个正数,表示需要等待的事件数量。countDown方法递减计数器,表示有一个事件发生了,而await方法等待计数器达到零,这表示所有需要等待的事件都已经发生。如果计数器的值非零,那么await会一直阻塞直到计数器为零,或者等待中的线程中断,或者等待超时。

 

await()方法

Causes the current thread to wait until the latch has counted down to zero

/**
 * Causes the current thread to wait until the latch has counted down to
 * zero, unless the thread is {@linkplain Thread#interrupt interrupted}.
 */
public void await() throws InterruptedException {
    sync.acquireSharedInterruptibly(1);
}

 

countDown()方法

Decrements the count of the latch, releasing all waiting threads if  the count reaches zero

/**
 * Decrements the count of the latch, releasing all waiting threads if
 * the count reaches zero.
 */
public void countDown() {
    sync.releaseShared(1);
}

 

CountDownLatch示例

在下面这个示例中,它使用两个闭锁,分别表示起始门,和结束门。

起始门计数器的初始值为 1,而结束门计数器的初始值为工作线程的数量。每个工作线程首先要做的就是在启动门上等待,从而确保所有的线程都就绪后才开始执行。而每个线程要做的最后一件事就是将调用结束门的countDown 方法减一,这能使主线程高效的等待直到所有的工作线程都执行完成,因此可以统计所消耗的时间:

package com.lyx;

import java.util.concurrent.CountDownLatch;

public class TestHarness {

	public static void main(String[] args) throws InterruptedException {
		// TODO Auto-generated method stub
		Runnable task = new Runnable() {
			public void run() {
				System.out.println("hello latch............");
			}
		};
		System.out.println(timeTashs(100, task));
	}

	public static long timeTashs(int nThreads, final Runnable task)
			throws InterruptedException {
		final CountDownLatch startGate = new CountDownLatch(1);
		final CountDownLatch endGate = new CountDownLatch(nThreads);

		for (int i = 0; i < nThreads; i++) {

			Thread t = new Thread() {
				@Override
				public void run() {
					try {
						startGate.await();//startGate 计数器为 1,等待直到计数器为零
						try {
							task.run();
						} finally {
							endGate.countDown(); //结束门计数器递减 1 
						}
					} catch (InterruptedException e) {
						// TODO: handle exception
					}
				}
			};
			t.start();
		}

		long start = System.nanoTime();
		startGate.countDown(); //计数器减一,所有的工作线程同一时间开始工作。
		endGate.await(); //主线程结束工作-If the current count is zero then this method returns immediately.
		long end = System.nanoTime();
		return end - start;
	}

}

 

下面示例来自http://lbxc.iteye.com/blog/1717482

public long runSample(int n, final Runnable runSport) throws InterruptedException {
    final CountDownLatch gun = new CountDownLatch(1);
    final CountDownLatch end = new CountDownLatch(n);
    
    for (int i = 0; i < n; i++){
        Thread t = new Thread() {
            public void run(){
                try{
                gun.await();//等待开枪
                try{
                runSport.run();
                }finally{
                    end.countDown();
                }
                }catch( InterruptedException e){
                    Thread.currentThread().interrupt();
                }
            }
        };
        t.start();
    }
    long startTime = System.nanoTime();
    gun.countDown();//开枪
    end.await();
    long endTime = System.nanoTime();
    return endTime - startTime;
}

============END============

© 著作权归作者所有

共有 人打赏支持
秋风醉了
粉丝 237
博文 578
码字总数 419908
作品 0
朝阳
程序员
Java中如何模拟真正的同时并发请求?

原文出处:等你归去来 有时需要测试一下某个功能的并发性能,又不要想借助于其他工具,索性就自己的开发语言,来一个并发请求就最方便了。 Java 中模拟并发请求,自然是很方便的,只要多开几...

等你归去来
10/08
0
0
Java多线程打辅助的三个小伙子

之前学多线程的时候没有学习线程的同步工具类(辅助类)。ps:当时觉得暂时用不上,认为是挺高深的知识点就没去管了.. 在前几天,朋友发了一篇比较好的Semaphore文章过来,然后在浏览博客的时候...

Java3y
07/27
0
0
CountDownLatch类的使用

CountDownLatch介绍 JDk1.5提供了一个非常有用的包,Concurrent包,这个包主要用来操作一些并发操作,提供一些并发类,可以方便在项目当中傻瓜式应用。 JDK1.5以前,使用并发操作,都是通过T...

ZeroOne01
04/26
0
0
Java并发编程-CountDownLatch

1、 应用场景   CountDownLatch是并发包中用来控制一个或者多个线程等待其他线程完成操作的并发工具类。现以工作中的一个场景来描述下CountDownLatch的应用,代码如下: /*模拟工作中的一个...

Ala6
10/03
0
0
《Java并发编程实战》读书笔记五:深入理解同步实现

一、构建自定义的同步工具 1. 内置的条件队列 条件队列就如同烤面包机上的面包已好的铃声。如果你正在听着它, 当面包烤好后你可以立即注意到, 并且放下手头的事情开始品尝面包, 如果你没有听...

小七奇奇
08/17
0
0

没有更多内容

加载失败,请刷新页面

加载更多

原型模式

1、原型模式-定义 用原型实例指定创建对象的种类,并且通过拷贝这些原型创建新的对象 克隆(浅度克隆->拷贝值类型或者引用,深度克隆->创建新的对象,开辟新的内存) 例如客户端知道抽象Pro...

阿元
今天
36
0
awk命令扩展使用操作

awk 中使用外部shell变量 示例1 [root@centos01 t1022]# A=888[root@centos01 t1022]# echo "" | awk -v GET_A=$A '{print GET_A}'888[root@centos01 t1022]# echo "aaaaaaaaaaaaa" | aw......

野雪球
今天
29
0
深入解析MySQL视图VIEW

Q:什么是视图?视图是干什么用的? A:视图(view)是一种虚拟存在的表,是一个逻辑表,本身并不包含数据。作为一个select语句保存在数据字典中的。   通过视图,可以展现基表的部分数据;...

IT--小哥
今天
40
0
虚拟机学习之二:垃圾收集器和内存分配策略

1.对象是否可回收 1.1引用计数算法 引用计数算法:给对象中添加一个引用计数器,每当有一个地方引用它时,计数器值就加1;当引用失效时,计数器值就减1;任何时候计数器值为0的对象就是不可能...

贾峰uk
今天
28
0
smart-doc功能使用介绍

smart-doc从8月份底开始开源发布到目前为止已经迭代了几个版本。在这里非常感谢那些敢于用smart-doc去做尝试并积极提出建议的社区用户。因此决定在本博客中重要说明下smart-doc的功能,包括使...

上官胡闹
昨天
39
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部