jdk 已经给提供了创建线程池的方法:

都是这个包下的

import java.util.concurrent.*;

//第一种创建固定线程池

ExecutorService executors1 =Executors.newFixedThreadPool(10);

//第二种创建一个线程的线程池

ExecutorService executors2= Executors.newSingleThreadExecutor();

//第三种创建一个没有容量限制的线程池

ExecutorService executors3= Executors.newCachedThreadPool();

//第四种 

ExecutorService executors4= Executors.newScheduledThreadPool(10);

关于此线程池

class Tempextends Thread {

public void run() {

System.out.println("run");

    }

}

public class ScheduledJob {

public static void main(String args[])throws Exception {

Temp command =new Temp();

        ScheduledExecutorService scheduler = Executors.newScheduledThreadPool(1);

        /**

        *  启动 5秒后 每1秒执行一次

        *

        */

        ScheduledFuture scheduleTask = scheduler.scheduleWithFixedDelay(command, 5, 1, TimeUnit.SECONDS);

    }

}

看底层源码回发现 其实都是

ThreadPoolExecutor 的实例实现而已.

自定义线程池

public ThreadPoolExecutor(int corePoolSize,

                          int maximumPoolSize,

                          long keepAliveTime,

                          TimeUnit unit,

                          BlockingQueue workQueue,

                          ThreadFactory threadFactory,

                          RejectedExecutionHandler handler)

int corePoolSize 核心线程数 --初始化的时候会创建这几个线程

 int maximumPoolSize  最大线程数 --核心线程已经占满,然后会创建新的线程.

long keepAliveTime 线程存活数字

 TimeUnit unit  线程存活数字的单位 

 BlockingQueue workQueue 当线程池中的线程都在使用时候,然后把新来的任务放到这个队列里等待执行.

ThreadFactory threadFactory : 创建线程工厂(一般用系统默认的就行)

RejectedExecutionHandler handler  这是意思是 当前的线程数量已经满了,而且 workQueue 也满了 然后执行拒绝来的任务.