当前位置:首页 > 开发 > 编程语言 > 多线程 > 正文

CountDownLatch线程同步辅助

发表于: 2014-06-18   作者:bughope   来源:转载   浏览次数:
摘要: http://bughope.iteye.com/blog/2081935 在上一篇文章中写道用一个静态的变量保存线程的执行状态,并用时间等待的方法后来仔细考虑,其实是 线程不安全的.多个线程同时执行这个类时,这个静态变量的值就不能保证了. 用一个线程同步的Map保存这个值,勉强能实现[每个线程生产一个不重复的map的key] 但是这样很麻烦. java. util. concur

http://bughope.iteye.com/blog/2081935

在上一篇文章中写道用一个静态的变量保存线程的执行状态,并用时间等待的方法后来仔细考虑,其实是

线程不安全的.多个线程同时执行这个类时,这个静态变量的值就不能保证了.

用一个线程同步的Map保存这个值,勉强能实现[每个线程生产一个不重复的map的key]

但是这样很麻烦.

java. util. concurrent.CountDownLatch 

却能完美的实现.能线程安全的计数,因为每个实现的主线程在并发的情况下java.util.concurrent.CountDownLatch; 是新的实例 不会像上一篇一样需要处理计数器的线程安全.

具体代码如下

package org.masque.effective;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;
/**
 * 
 * @author masque.java@gmail.com
 *
 */
public class ThreadTest {

	public static void main(String[] args) throws InterruptedException {
		CountDownLatch latch=new CountDownLatch(3);//数量标示线程的个数
		(new Thread1(latch)).start();
		(new Thread2(latch)).start();
		(new Thread3(latch)).start();
		latch.await();//等待线程执行完成.还有一个重载的方法可以设置超时时间
		System.out.println("over!");
	}
}

class Thread1 extends Thread{
	
	CountDownLatch latch;
	
	public Thread1(CountDownLatch latch){
		this.latch = latch;
	}
	
	@Override
	public void run() {
		for (int i=10;i<20;i++) {
			System.out.println("Thread1===========:"+i);
			try {
				TimeUnit.SECONDS.sleep(1);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		latch.countDown();//完成后计数
	}
}

class Thread2 extends Thread{
	
	CountDownLatch latch;
	
	public Thread2(CountDownLatch latch){
		this.latch = latch;
	}
	
	@Override
	public void run() {
		for (int i=10;i<20;i++) {
			System.out.println("Thread2===========:"+i);
			try {
				TimeUnit.SECONDS.sleep(1);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		latch.countDown();//完成后计数
	}
}

class Thread3 extends Thread{
	
	CountDownLatch latch;
	
	public Thread3(CountDownLatch latch){
		this.latch = latch;
	}
	
	@Override
	public void run() {
		for (int i=10;i<20;i++) {
			System.out.println("Thread3===========:"+i);
			try {
				TimeUnit.SECONDS.sleep(1);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		latch.countDown();//完成后计数
	}
}

 

CountDownLatch线程同步辅助

  • 0

    开心

    开心

  • 0

    板砖

    板砖

  • 0

    感动

    感动

  • 0

    有用

    有用

  • 0

    疑问

    疑问

  • 0

    难过

    难过

  • 0

    无聊

    无聊

  • 0

    震惊

    震惊

编辑推荐
在编写多线程的工作中,有个常见的问题:主线程(main) 启动好几个子线程(task)来完成并发任务,
CountDownLatch 是一个通用同步工具,它有很多用途,将计数 1 初始化的 CountDownLatch 用作一个简单
CountDownLatch 是一个通用同步工具,它有很多用途,将计数 1 初始化的 CountDownLatch 用作一个简单
线程间的竞争叫做Racing,正如这篇文章的图片一样,不同的线程好比在高速赛道上行驶的F1方程式赛车
线程间的竞争叫做Racing,正如这篇文章的图片一样,不同的线程好比在高速赛道上行驶的F1方程式赛车
public class TraditionalSychronized { /** * @param args */ public static void main(String[] a
线程同步: 一、线程同步: 线程的同步,就是要保证线程在执行某个计算时,需要保证相关的数据在这个
线程同步: 一、线程同步: 线程的同步,就是要保证线程在执行某个计算时,需要保证相关的数据在这个
代码 using System; using System.Collections.Generic; using System.Linq; using System.Text; us
目录: 一、线程同步概述 二、线程同步的使用 三 、总结 一、线程同步概述 前面的文章都是讲创建多
版权所有 IT知识库 CopyRight © 2009-2015 IT知识库 IT610.com , All Rights Reserved. 京ICP备09083238号