java executor Java线程池ThreadPoolExecutor&Executors

java executor Java线程池ThreadPoolExecutor&Executors

一、先看看传统的开启线程。

new Thread(new Runnable() {
    @Override
    public void run() {
    }
}).start();

缺点：

1、每次new 新建对象性能差。

2、线程缺乏统一管理，可能无限制新建线程java executor，相互之间竞争，及可能占用过多系统资源导致死机或oom。

3、缺乏更多功能，如定时执行、定期执行、线程中断。

二、在看看。

构造函数：

public ThreadPoolExecutor(int corePoolSize,
        int maximumPoolSize,
        long keepAliveTime,
        TimeUnit unit,
        BlockingQueue workQueue,
        ThreadFactory threadFactory,
        RejectedExecutionHandler handler) {}

参数说明：

：线程池核心线程数（平时保留的线程数）

：线程池最大线程数（当都放不下时java executor Java线程池ThreadPoolExecutor&Executors，启动新线程，最大线程数）

：超出数量的线程的保留时间。

unit：单位

：阻塞队列，存放来不及执行的线程

：构造函数一定要传大小

：构造函数不传大小会默认为（. ），当大量请求任务时，容易造成 内存耗尽。

：同步队列，一个没有存储空间的阻塞队列 ，将任务同步交付给工作线程。

e : 优先队列

：线程工厂

：饱和策略

（默认）：直接抛弃

：用调用者的线程执行任务

：抛弃队列中最久的任务

：抛弃当前任务

划重点：

1、当线程池小于时，新提交任务将创建一个新线程执行任务java executor，即使此时线程池中存在空闲线程。

2、当线程池达到时，新提交任务将被放入中，等待线程池中任务调度执行

3、当已满，且maximumPoolSize>时，新提交任务会创建新线程执行任务

4、当提交任务数超过时，新提交任务由dler处理

5、当线程池中超过线程，空闲时间达到时，关闭空闲线程

6、当设置ut(true)时，线程池中线程空闲时间达到也将关闭

三、可创建预定义的线程池

1、：创建一个定长线程池，可控制线程最大并发数，超出的线程会在队列中等待。

    public static ExecutorService newFixedThreadPool(int nThreads) {
        return new ThreadPoolExecutor(nThreads, nThreads,
                                      0L, TimeUnit.MILLISECONDS,
                                      new LinkedBlockingQueue());
    }

特点：

1）、与相等，即其线程全为核心线程，是一个固定大小的线程池，是其优势；

2）、 = 0 该参数默认对核心线程无效，而全部为核心线程；

3）、 为（无界阻塞队列），队列最大值为.。如果任务提交速度持续大余任务处理速度，会造成队列大量阻塞。因为队列很大java executor，很有可能在拒绝策略前，内存溢出。是其劣势；

4）、的任务执行是无序的；

适用场景：可用于Web服务瞬时削峰，但需注意长时间持续高峰情况造成的队列阻塞。

2、：创建一个可缓存线程池，如果线程池长度超过处理需要，可灵活回收空闲线程，若无可回收java executor Java线程池ThreadPoolExecutor&Executors，则新建线程。

    public static ExecutorService newCachedThreadPool() {
        return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                      60L, TimeUnit.SECONDS,
                                      new SynchronousQueue());
    }

特点：

1）、 = 0， = .，即线程数量几乎无限制；

2）、 = 60s，线程空闲60s后自动结束。

3）、 为 同步队列，这个队列类似于一个接力棒，入队出队必须同时传递，因为线程创建无限制，不会有队列等待，所以使用；

适用场景：快速处理大量耗时较短的任务，如Netty的NIO接受请求时，可使用。

3、：创建一个单线程化的线程池，它只会用唯一的工作线程来执行任务，保证所有任务按照指定顺序（FIFO, LIFO, 优先级）执行。

    public static ExecutorService newSingleThreadExecutor() {
        return new FinalizableDelegatedExecutorService
            (new ThreadPoolExecutor(1, 1,
                                    0L, TimeUnit.MILLISECONDS,
                                    new LinkedBlockingQueue()));
    }

4、：创建一个定长线程池，支持定时及周期性任务执行。

    public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
        return new ScheduledThreadPoolExecutor(corePoolSize);
    }

代码样例：

public class Test {
    private ExecutorService cachePool = Executors.newCachedThreadPool();
    private void test() {
        for (int i = 0; i < 10; i++) {
            cachePool.execute(new Job());
        }
        cachePool.shutdown();
    }
    class Job implements Runnable {
        @Override
        public void run() {
            System.out.println("执行任务");
            try {
                Thread.sleep(3000);
            } catch (InterruptedException e) {
            }
        }
    }
    public static void main(String[] args) {
        new ExecutorServiceTest().test();
    }
}

参考：