java线程池源码的简单分析

时间：2019-12-28 13:24:37 阅读：86 评论：0 收藏：0 [点我收藏+]

标签：时间设置 runnable run inf 回收工作任务 executors nbsp future

　　工作中用过线程池来进行多线程的操作，但是也仅仅是停留在使用方面，没有深入研究，现在通过源码来仔细研究下java的线程池。关于线程池的优缺点就不研究了，直接通过一个源码来看看java中线程池的原理。

　　使用ThreadPoolExecutor来创建一个线程池

public class MultipleThread {
    public static void main(String[] args) {
        /**
         * 通过ThreadPoolExecutor来创建一个线程池
         *
         * 我们创建的线程池  核心线程数为10，最大线程数为10，也就是线程池的大小就是为10个线程
         *
         * 非核心线程的在没有任务执行的时候存活的时间设置为0，时间单位是毫秒(设置为0意味着不过期，不会超时被回收)
         * 
         * LinkedBlockingQueue作为工作队列，用于存储工作任务
         */

        ExecutorService executorService = new ThreadPoolExecutor(10, 10,
                0L, TimeUnit.MILLISECONDS,
                new LinkedBlockingQueue<Runnable>());
        Future<?> a = executorService.submit(() ->
            System.out.println("当前线程：" + Thread.currentThread().getName())
        );
        Future<?> aa = executorService.submit(() ->
                System.out.println("当前线程：" + Thread.currentThread().getName()));
        Future<?> aaa = executorService.submit(() ->
                System.out.println("当前线程：" + Thread.currentThread().getName()));
        Future<?> aaaa = executorService.submit(() ->
                System.out.println("当前线程：" + Thread.currentThread().getName()));
        Future<?> aaaaa = executorService.submit(() ->
                System.out.println("当前线程：" + Thread.currentThread().getName()));

    }
}