import java.util.ArrayList;
import java.util.List;
import java.util.Random;
import java.util.concurrent.BrokenBarrierException;
import java.util.concurrent.Callable;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.CyclicBarrier;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
import java.util.concurrent.FutureTask;
import java.util.concurrent.atomic.AtomicInteger;
public class TestCountDownLatch {
private static List<String> mans = new ArrayList<String>();
private static CyclicBarrier barrier = null;
private static AtomicInteger costTimes = new AtomicInteger(0);
static {
mans.add("andy");
mans.add("jack");
mans.add("lili");
mans.add("alan");
mans.add("bill");
//barrier = new CyclicBarrier(mans.size() + 1);
}
public static class Walk implements Runnable {
private AtomicInteger ct = new AtomicInteger(0);
private String name;
private CountDownLatch latch;
public Walk(String name, AtomicInteger countTime, CountDownLatch cdl) {
ct = countTime;
this.name = name;
// latch = cdl;
}
@Override
public void run() {
int walkTime = new Random().nextInt(20);
try {
if ("lili".equals(name)) {
Thread.sleep(10000);
} else
Thread.sleep(1000);
} catch (InterruptedException e) {
}
System.out.println(name + " walk " + walkTime + "min");
// ct.addAndGet(walkTime);
// try {
// // barrier.await();
// latch.countDown();
// } catch (Exception e) {
//
// }
System.out.println(name + " walk over!");
System.out.println("all person walk " + ct.addAndGet(walkTime));
}
}
public static class Walk1 implements Callable<Integer> {
private String name;
public Walk1(String n) {
this.name = n;
}
@Override
public Integer call() {
int walkTime = new Random().nextInt(20);
try {
if ("lili".equals(name)) {
Thread.sleep(10000);
} else
Thread.sleep(1000);
} catch (InterruptedException e) {
}
System.out.println(name + " walk " + walkTime + "min");
return walkTime;
}
}
public static void main(String[] args) throws Exception {
// try {
// CountDownLatch latch = new CountDownLatch(mans.size());
// ExecutorService es = Executors.newFixedThreadPool(mans.size());
// for (String str : mans) {
// es.submit(new Walk(str, costTimes, latch));
// }
//
// es.shutdown();
// // latch.await();
// //barrier.await();
// System.out.println("TOTAL COST:" + costTimes + "min");
// } catch (Exception e) {
// System.out.println(e.getMessage());
// } finally {
//
// }
List<Future<Integer>> tasks = new ArrayList<Future<Integer>>();
ExecutorService es = Executors.newFixedThreadPool(mans.size());
for (String str : mans) {
Walk1 w = new Walk1(str);
FutureTask<Integer> f = new FutureTask<Integer>(w);
tasks.add(f);
es.submit(f);
}
es.shutdown();
Integer costTimes = 0;
for (Future<Integer> f : tasks) {
costTimes += f.get();
}
System.out.println("TOTAL COST:" + costTimes + "min");
}
}
计算几个人跑步总时间。。。
分享到:
相关推荐
在网上找的一个CountDownLatch的学习demo,感觉很不错,就摘抄过来了
《java并发编程》中CountDownLatch和CyclicBarrier用法实例大全,几乎包含了所有重要的用法
利用 CountDownLatch 类实现线程同步,而不用回调机制。详见我的博文 http://blog.csdn.net/kroclin/article/details/37956949
递减锁存器CountDownLatch的使用以及注意事项!
目录 CountDownLatch是什么? CountDownLatch如何工作? 在实时系统中的应用场景 应用范例 常见的面试题 代码样例
CountDownLatch与thread.join()的区别
NULL 博文链接:https://cpjsjxy.iteye.com/blog/2272451
CountDownLatch Demo
mybaits 多线程 实现数据批量插入 (运用CountDownLatch实现闭锁) 1、mybatis批处理 2、数据分批量查询 3、数据分批量插入
java并发编程中CountDownLatch和CyclicBarrier的使用借鉴.pdf
并发编程之CountDownLatch
1.2 CountDownLatch概述 CountDownLatch的基本用法 2.1 创建CountDownLatch对象 2.2 await()方法 2.3 countDown()方法 实现多线程任务的同步 3.1 场景介绍 3.2 使用CountDownLatch实现同步 主线程等待多个线程完成 ...
Java并发编程一CountDownLatch、CyclicBarrier、Semaphore初使用 CountDownLatch、CyclicBarrier、Semaphore这些线程协作工具类是基于AQS的,看完这篇博客后可以去看下面这篇博客,了解它们是如何实现的。 Java并发...
CountDownLatch是一个同步工具类,它通过一个计数器来实现的,初始值为线程的数量。每当一个线程完成了自己的任务,计数器的值就相应得减1。当计数器到达0时,表示所有的线程都已执行完毕,然后在等待的线程就可以恢复...
主要为大家详细介绍了Java中CountDownLatch用法,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
其实我自认为CountDownLatch类是进入AQS世界一个非常好非常好的通道,因此写完这篇文章,我打算再写一篇关于CountDownLatch源码的文章。 1 原理简介 CountDownLatch原理可以用下图进行表示: 这里注意一下: 每个...
主要介绍了如何使用CountDownLatch同步java多线程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
TestSemaphore、TestLock、TestCyclicBarrier、CountdownLatchTest、LRUCache 博文链接:https://uule.iteye.com/blog/1543958
6.3 Semaphorer&CountDownLatch详 解副本.mp4
java并发工具类(CountDownLatch+Semaphore+Exchanger);java并发工具类(CountDownLatch+Semaphore+Exchanger);java并发工具类(CountDownLatch+Semaphore+Exchanger);java并发工具类(CountDownLatch+...