Java多线程与并发库高级应用-线程池

public class ThreadPoolTest {

    public static void main(String[] args) {
//        ExecutorService threadPool = Executors.newFixedThreadPool(3); //创建一个固定大小的线程池，线程池中有3个线程可以同时服务
        //缓存线程池 线程池中的线程数是动态变化的，当所有线程处于服务状态时，还有需要被服务的任务，自动增加一个线程进行服务
        //当任务执行完毕，线程处于空闲一段时间，超时后则自动回收销毁线程
//        ExecutorService threadPool = Executors.newCachedThreadPool();  
        //创建一个只有一个线程的线程池，当这个线程挂掉时，可以自动生成一个线程来代替
        //可以解决一个网上很多人问的问题(如何实现线程死掉后重新启动?)
        ExecutorService threadPool = Executors.newSingleThreadExecutor();   
        for(int i = 0;i<10;i++){  //往线程池中扔10个任务，同时被服务的有3个，其他线程进行排队
            final int task = i;
            threadPool.execute(new Runnable() {  //往线程池中扔了一个任务
                
                @Override
                public void run() {
                    for(int j = 0;j<10;j++){
                        System.out.println(Thread.currentThread().getName()+" is loop of "+ j + "the task of "+task);
                    }
                }
            });
        }
        System.out.println("all of 10 tasks have committed");
        //上述代码执行完后 没有结束，线程池中有3个线程一直存在，所以程序不会结束
        //可以使用 threadPool.shutdown()
        threadPool.shutdown();  //当线程池中线程执行完所有任务，所有线程处于空闲状态时，干掉所有线程，程序自结束
//        threadPool.shutdownNow();  //立即把池子中所有线程干掉，无论任务是否干完
        
    }
}

Executors.newScheduledThreadPool(3).schedule(
                new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("bombing!");
                    }
                }, 
                10, 
                TimeUnit.SECONDS);

//固定频率 10秒后触发，每隔两秒后执行一次
        Executors.newScheduledThreadPool(3).scheduleAtFixedRate(
                new Runnable() {
                    @Override
                    public void run() {
                        System.out.println("bombing!");
                    }
                }, 
                10, 
                2,
                TimeUnit.SECONDS);
        //在使用scheduleAtFixedRate 时java api没有提供在某个时间点触发，但API中提示可以通过计算，得到触发的事件点
        // For example, to schedule at a certain future date,
        // you can use: schedule(task, date.getTime() - System.currentTimeMillis(), TimeUnit.MILLISECONDS).