ThreadPoolExecutor线程池

package unit;

import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class ThreadPoolExecutor线程池 {
    public static void main(String[] args) {
        ThreadPoolExecutor executorPool = new ThreadPoolExecutor(5, 15, 2000, TimeUnit.MINUTES, new ArrayBlockingQueue<Runnable>(5));
        for(int i=0; i<15; i++) {
            executorPool.execute(new MyTask(i));
            System.out.println("线程池中线程数目："+executorPool.getPoolSize()+"，队列中等待执行的任务数目："+
            executorPool.getQueue().size()+"，已执行过的任务数目："+executorPool.getCompletedTaskCount());
        }
        System.out.println("=========================");
        executorPool.shutdown();
        executorPool.setKeepAliveTime(2, TimeUnit.MINUTES);
        
    }
}

class MyTask implements Runnable{
    int theTask = 0;
    public MyTask() {
        
    }
    public MyTask(int i) {
        theTask = i;
        run();
    }
    @Override
    public void run() {
        System.out.println("当前正在执行第： "+ theTask + " 个线程");
        /* try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }*/
        System.out.println("task "+theTask+"执行完毕");
    }
}