Java实现监控多个线程状态的简单实例

实例如下:

成都创新互联公司-专业网站定制、快速模板网站建设、高性价比泸水网站开发、企业建站全套包干低至880元,成熟完善的模板库,直接使用。一站式泸水网站制作公司更省心,省钱,快速模板网站建设找我们,业务覆盖泸水地区。费用合理售后完善,10多年实体公司更值得信赖。

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

/**
 * 测试监控类
 * 
 * @author
 * 
 */
public class WatchThread {

 /**
 * 测试函数
 * 
 * @throws InterruptedException
 */
 public void testThread() throws InterruptedException {
 int threadNum = 10;
 // 初始化countDown
 CountDownLatch threadSignal = new CountDownLatch(threadNum);
 // 创建固定长度的线程池
 Executor executor = Executors.newFixedThreadPool(threadNum);
 for (int i = 0; i < threadNum; i++) { // 开threadNum个线程
  Runnable task = new TestThread(threadSignal);
  // 执行
  executor.execute(task);
 }
 threadSignal.await(); // 等待所有子线程执行完
 // do work
 System.out.println(Thread.currentThread().getName() + "+++++++结束.");
 }

 /**
 * 测试函数
 */
 public static void main(String[] args) throws InterruptedException {
 WatchThread test = new WatchThread();
 test.testThread();
 }

 /**
 * 
 * @author jill
 * 
 */
 private class TestThread implements Runnable {
 private CountDownLatch threadsSignal;

 public TestThread(CountDownLatch threadsSignal) {
  this.threadsSignal = threadsSignal;
 }

 public void run() {
  System.out.println(Thread.currentThread().getName() + "开始...");
  // do shomething
  System.out.println("开始了线程::::" + threadsSignal.getCount());
  // 线程结束时计数器减1
  threadsSignal.countDown();  //这句代码 建议放在 finally里执行 
  System.out.println(Thread.currentThread().getName() + "结束. 还有"
   + threadsSignal.getCount() + " 个线程");
 }
 }

}

以上这篇Java实现监控多个线程状态的简单实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持创新互联。


网页题目:Java实现监控多个线程状态的简单实例
文章分享:http://bzwzjz.com/article/igpjgh.html

其他资讯

Copyright © 2007-2020 广东宝晨空调科技有限公司 All Rights Reserved 粤ICP备2022107769号
友情链接: 重庆网站制作 攀枝花网站设计 网站建设 成都网站制作 成都网站建设 成都网站制作公司 高端网站设计推广 温江网站设计 外贸营销网站建设 移动手机网站制作 手机网站制作设计 企业网站制作 企业网站设计 成都网站建设推广 手机网站设计 成都品牌网站设计 成都定制网站建设 温江网站设计 成都网站设计 重庆电商网站建设 成都网站设计 网站制作