多线程模拟记者发布会。每个记者提一个问题,且发布会要等每个记者问题准备好,会议才能开始,待所有记者发问完后,会议结束。
下面是模拟实例:
package cn.com.ld.study.thread;
/**
* @filename: Reporter
* @description: 记者
* @author lida
* @date 2013-3-29 下午1:35:01
*/
public class Reporter {
private String name;
private String question;
Reporter(String name, String question) {
this.name = name;
this.question = question;
}
public void ask() {
System.out.println(name + "的问题是:" + this.question);
}
public String getName() {
return name;
}
}
package cn.com.ld.study.thread;
import java.util.concurrent.CountDownLatch;
/**
* @filename: AskJob
* @description: 提问线程
* @author lida
* @date 2013-3-29 下午1:34:42
*/
public class AskJob extends Thread {
private Reporter reporter;
private CountDownLatch startMetting;
private CountDownLatch endMetting;
AskJob(Reporter reporter, CountDownLatch startMetting,
CountDownLatch endMetting) {
this.reporter = reporter;
this.startMetting = startMetting;
this.endMetting = endMetting;
}
public void run() {
try {
sleep(2000);
startMetting.await();
reporter.ask();
endMetting.countDown();
} catch (InterruptedException e) {
e.printStackTrace();
Thread.currentThread().interrupt();
}
}
}
package cn.com.ld.study.thread;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.CountDownLatch;
/**
* @filename: ReporterMetting
* @description: 会议现场
* @author lida
* @date 2013-3-29 下午1:35:20
*/
public class ReporterMetting extends Thread {
private int reporeterNo;
private CountDownLatch startMetting;
private CountDownLatch endMetting;
private List<Reporter> repList;
ReporterMetting(int reporeterNo, List<Reporter> repList,
CountDownLatch start) {
this.reporeterNo = repList.size();
this.repList = repList;
this.startMetting = start;
this.endMetting = new CountDownLatch(reporeterNo);
}
public void run() {
System.out.println("-----Metting is start----");
AskJob aj = null;
for (int i = 0; i < this.reporeterNo; i++) {
Reporter reporter = repList.get(i);
aj = new AskJob(reporter, startMetting, endMetting);
aj.start();
}
// 待所有的问题准备就绪后,会议真正的开始
startMetting.countDown();
try {
// 等待askjob 全部执行完毕唤醒 结束会议通知
endMetting.await();
System.out.println("-----Metting is end----");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
public static void main(String[] args) {
List<Reporter> repList = new ArrayList<Reporter>();
int reporeterNo = 10;
Reporter reporter;
for (int i = 1; i <= reporeterNo; i++) {
reporter = new Reporter("狗仔" + i + "号", "开了" + i + "几瓶茅台,够不够喝?");
repList.add(reporter);
}
CountDownLatch startMetting = new CountDownLatch(1);
ReporterMetting rm = new ReporterMetting(reporeterNo, repList,
startMetting);
rm.start();
}
}
测试结果:
-----Metting is start----
狗仔2号的问题是:开了2几瓶茅台,够不够喝?
狗仔5号的问题是:开了5几瓶茅台,够不够喝?
狗仔6号的问题是:开了6几瓶茅台,够不够喝?
狗仔3号的问题是:开了3几瓶茅台,够不够喝?
狗仔8号的问题是:开了8几瓶茅台,够不够喝?
狗仔4号的问题是:开了4几瓶茅台,够不够喝?
狗仔1号的问题是:开了1几瓶茅台,够不够喝?
狗仔7号的问题是:开了7几瓶茅台,够不够喝?
狗仔10号的问题是:开了10几瓶茅台,够不够喝?
狗仔9号的问题是:开了9几瓶茅台,够不够喝?
-----Metting is end----
分享到:
相关推荐
《java并发编程》中CountDownLatch和CyclicBarrier用法实例大全,几乎包含了所有重要的用法
- 其他 N 个线程必须引用闭锁对象,因为它们如果完成了任务需要通过 CountDownLatch.countDown() 方法来通知CountDownLatch实例,每次调用计数减少 1。当所有 N 个线程都调用了这个方法时,计数将达到 0,主线程...
主要介绍了Java CountDownLatch完成异步回调实例详解的相关资料,需要的朋友可以参考下
主要介绍了Java中CountDownLatch进行多线程同步详解及实例代码的相关资料,需要的朋友可以参考下
主要介绍了Java多线程编程之CountDownLatch同步工具使用实例,需要的朋友可以参考下
主要介绍了JAVA CountDownLatch(倒计时计数器)用法实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
Java并发工具包实例,包含AQS,LOCK,countdownlatch ,atomic原子类等实例
主要介绍了Java并发编程:CountDownLatch与CyclicBarrier和Semaphore的实例详解的相关资料,需要的朋友可以参考下
有以下类的实例: ThreadPool ScheduledThread CyclicBarrier BlockingQueue CountDownLatch FutureTask CompletionService Semaphore
主要介绍了java CountDownLatch的相关资料,文中示例代码非常详细,帮助大家理解和学习,感兴趣的朋友可以了解下
全部代码出自电子工业出版社夏先波的《Java JDK实例宝典》一书,本书以J2SE 5.0为开发环境,选取Java应用的典型实例,循序渐进地介绍了Java语言的各种开发方法和技巧,实例代码注释详细规范,思路清晰。 第1章 ...
Concurrent下的例子,涵盖了大部分常用类 例如BlockingQueue、CountDownLatch、CyclicBarrier、Exchanger、ExecuteService、lock、timeutil等
synchronized关键字加在静态方法和实例方法的区别; 用锁的注意点; cas机制可能导致的问题ABA,什么是ABA; 程序开多少线程合适; 实现一下DCL(双重检查锁) stream 和 parallelStream区别; 实现一个阻塞队列(用...
分布式计算的原语,例如AtomicLong , AtomicReference和CountDownLatch 。 Hazelcast数据结构在内存中,经过高度优化,并提供了非常低的延迟。 对于IMap上的单个get或put操作,通常可以预期往返时间不到100微秒。...
同步控制是并发程序必不可少的重要手段,本文我们将通过重入锁、读写锁、信号量、倒计数器和循环栅栏以及他们的实例来介绍Java并发程序中的同步控制。 目录线程安全 Thread Safety重入锁 ReentrantLock读写锁 ...
CountDownLatch:可以使一个或多个线程等待一组事件发生 FutureTask *应用场景 (1)用作异步任务使用,且可以使用get方法获取任务的结果 (2)用于表示一些时间较长的计算 状态 ...
14.6.2 Semaphore与CountDownLatch258 14.6.3 FutureTask259 14.6.4 ReentrantReadWriteLock259 第15章 原子变量与非阻塞同步机制261 15.1 锁的劣势261 15.2 硬件对并发的支持262 15.2.1 比较并交换263 ...
1. 目录 1. 2. 目录 .........................................................................................................................................................1 JVM ........................