欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2024-03-05 22:09:37
实例如下: import java.util.concurrent.countdownlatch; import java.util.concurrent.ex...

实例如下:

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实现监控多个线程状态的简单实例就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。