5-线程池

package ThreadPool;

/*
* 创建线程池
* 线程池在Java中的代表类：ExcutorService(接口)
* Java在Executors类下提供一个静态方法得到一个线程池的对象
* public static ExecutorService newFixedThreadPool(int nThreads);
* （创建一个可重用固定线程数的线程池并返回，以共享的无界队列方式来运行这些线程）
* */

import java.util.concurrent.Executor;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolDemo {
    public static void main(String[] args) {
        //创建一个线程池，指定线程的固定数量是3
        ExecutorService pool= Executors.newFixedThreadPool(3);
        //添加线程任务给线程池处理
        Runnable task=new MyRunnable();
        //可以向线程池提交Runnable接口或Callable接口 ，Callable做线程池的任务可以得到线程执行的结果（返回值类型Future<?>）
        pool.submit(task);  //第一次向线程池提交任务，此时线程池创建新线程，自动触发执行，不需要再start()
        pool.submit(task);  //第二次向线程池提交任务，此时线程池创建新线程
        pool.submit(task);  //第三次向线程池提交任务，此时线程池创建新线程
        pool.submit(task);  //第四次向线程池提交任务，超出线程池固定数量，此时线程池复用之前的线程
        
        // pool.shutdown();  在等待任务执行完毕之后关闭线程池
        // pool.shutdownNow();  立即关闭线程池代码，无论任务是否执行完毕
        // 线程池开发中一般情况下不关闭
    }

}


class MyRunnable implements Runnable{

    @Override
    public void run() {
        for(int i=0;i<5;i++){
            System.out.println(Thread.currentThread().getName()+"==>"+i);
        }
    }
}