关于我们

质量为本、客户为根、勇于拼搏、务实创新

< 返回新闻公共列表

线程池的五种实现方式

发布时间:2020-08-06 10:43:00

其实线程池我更愿意说成四种封装实现方式,一种原始实现方式。这四种封装的实现方式都是依赖于最原始的的实现方式。所以这里我们先介绍四种封装的实现方式

2.1 Executors.newSingleThreadExecutor()

这个线程池很有意思,说是线程池,但是池子里面只有一条线程。如果线程因为异常而停止,会自动新建一个线程补充。
我们可以测试一下:
我们对线程池执行十条打印任务,可以发现它们用的都是同一条线程

    public static void test01() {

        ExecutorService threadPool = Executors.newSingleThreadExecutor();

        try {

            //对线程进行执行十条打印任务

            for(int i = 1; i <= 10; i++){

                threadPool.execute(()->{

                    System.out.println(Thread.currentThread().getName()+"=>执行完毕!");

                });

            }

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            //用完线程池一定要记得关闭

            threadPool.shutdown();

        }

    }

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

2.2 Executors.newFixedThreadPool(指定线程数量)

这个线程池是可以指定我们的线程池大小的,可以针对我们具体的业务和情况来分配大小。它是创建一个核心线程数跟最大线程数相同的线程池,因此池中的线程数量既不会增加也不会变少,如果有空闲线程任务就会被执行,如果没有就放入任务队列,等待空闲线程。
我们同样来测试一下:

    public static void test02() {

        ExecutorService threadPool = Executors.newFixedThreadPool(5);

        try {

            //对线程进行执行十条打印任务

            for(int i = 1; i <= 10; i++){

                threadPool.execute(()->{

                    System.out.println(Thread.currentThread().getName()+"=>执行完毕!");

                });

            }

        } catch (Exception e) {

            e.printStackTrace();

        } finally {

            //用完线程池一定要记得关闭

            threadPool.shutdown();

        }

    }

我们创建了五条线程的线程池,在打印任务的时候,可以发现线程都有进行工作

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-1=>执行完毕!

pool-1-thread-2=>执行完毕!

pool-1-thread-3=>执行完毕!

pool-1-thread-5=>执行完毕!

pool-1-thread-4=>执行完毕!

2.3 Executors.newCachedThreadPool()

这个线程池是创建一个核心线程数为0,最大线程为Inter.MAX_VALUE的线程池,也就是说没有限制,线程池中的线程数量不确定,但如果有空闲线程可以复用,则优先使用,如果没有空闲线程,则创建新线程处理任务,处理完放入线程池。
2.4 Executors.newScheduledThreadPool(指定最大线程数量)

创建一个没有最大线程数限制的可以定时执行线程池
在这里,还有创建一个只有单个线程的可以定时执行线程池(Executors.newSingleThreadScheduledExecutor())这些都是上面的线程池扩展开来了,不详细介绍了。



/template/Home/Zkeys/PC/Static