java线程池

public class ThreadPool {
public static void main(String[] args) {
ThreadPoolExecutor poolExecutor = new ThreadPoolExecutor(5,10,2, TimeUnit.SECONDS,new ArrayBlockingQueue<>(5));
 
for (int i=0;i<15;i++){
poolExecutor.execute(new Task(i));
System.out.println("线程池中线程数目："+poolExecutor.getPoolSize()+"，队列中等待执行的任务数目："+
poolExecutor.getQueue().size()+"，已执行完成的任务数目："+poolExecutor.getCompletedTaskCount());
}
for(;;) {
try {
//if (taskNum < 10) {
Thread.currentThread().sleep(3000);
//}
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("线程池中线程数目：" + poolExecutor.getPoolSize() + "，队列中等待执行的任务数目：" +
poolExecutor.getQueue().size() + "，已执行完成的任务数目：" + poolExecutor.getCompletedTaskCount());
}
//poolExecutor.shutdown();
}
}
class Task implements Runnable {
private int taskNum;
 
public Task(int taskNum){
this.taskNum = taskNum;
}
 
 
@Override
public void run() {
System.out.println("正在执行task "+taskNum);
try {
//if (taskNum < 10) {
Thread.currentThread().sleep(4000);
//}
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("task "+taskNum+"执行完毕");
}
}