public class App {
public static void main(String[] args) throws InterruptedException {
System.out.println("这是测试项目");
// ExecutorService executorService=Executors.newCachedThreadPool();
// Executors.newSingleThreadExecutor();
// Executors.newFixedThreadPool(100);
ExecutorService executorService = Executors.newFixedThreadPool(5);
// ThreadPoolExecutor executor = new ThreadPoolExecutor(5, 10, 200,
// TimeUnit.MICROSECONDS,
// new ArrayBlockingQueue<Runnable>(5));
while (true) {
for (int i = 0; i < 10; i++) {
Mytask mytask = new Mytask(i);
//executor.execute(mytask);
executorService.execute(mytask);
// System.out.println("线程池线程数目"+executor.getPoolSize()+"
// 等待的任务数目"+executor.getQueue().size()
// +",已执行完别的任务数目："+executor.getCompletedTaskCount());
System.out.println("当前线程活动数目：" + ((ThreadPoolExecutor) executorService).getActiveCount() + ",等待的任务数目:"
+ ((ThreadPoolExecutor) executorService).getTaskCount() + ",已执行完别的任务数目"
+ ((ThreadPoolExecutor) executorService).getCompletedTaskCount());
}
//executorService.shutdown();
//executor.shutdown();
System.out.println("主线程睡眠10秒 再执行~~~~~~~~~~~~~~~");
Thread.sleep(10000);
}
}
}
-----------------------------------------------------------
public class Mytask implements Runnable {
private int taskNum;
public Mytask(int num) {
this.taskNum = num;
}
@Override
public void run() {
System.out.println("正在执行task" + this.taskNum);
try {
Thread.currentThread();
Thread.sleep(4000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("task" + taskNum + "执行完毕");
}
}
--------------------注解
得到 ExecutorService 当前活动的线程数
https://blog.csdn.net/yingzishizhe/article/details/8769907
Java并发编程：线程池的使用(重点需要看)
http://www.cnblogs.com/dolphin0520/p/3932921.html
Java通过Executors提供四种线程池
https://www.cnblogs.com/webglcn/p/5265901.html
Executors创建的4种线程池的使用
https://www.cnblogs.com/ljp-sun/p/6580147.html