java基础之CachedThreadPool

这是大名鼎鼎的java4大线程池之一，具有以下特性

1、是一个可以无限扩大的线程池；

2、比较适合处理执行时间比较小的任务；

3、corePoolSize为0，maximumPoolSize为无限大，意味着线程数量可以无限大；

4、keepAliveTime为60S，意味着线程空闲时间超过60S就会被杀死；

采用SynchronousQueue装等待的任务，这个阻塞队列没有存储空间，这意味着只要有请求到来，就必须要找到一条工作线程处理他，如果当前没有空闲的线程，那么就会再创建一条新的线程。

使用场景:

检测A服务器在当前内网中的某个固定端口是否可用，那么检测的内容是A:8080 B:8080 C:8080 .....除了路由器占用一个剩下254个机器，如何用最短的时间去全部检测一遍。用下面的示例代码做法在非常短的时间即可完成全部检测。

示例代码：

ExecutorService executor = Executors.newCachedThreadPool();

Set<ServiceRoute> routeSet = new HashSet<>(cache.values());

try {

    final CountDownLatch cdOrder = new CountDownLatch(1);//一个控制线程

    final CountDownLatch cdAnswer = new CountDownLatch(1000);//执行线程

    for (ServiceRoute route : routeSet) {

        Runnable runnable = () -> {

            try {

                cdOrder.await(); // 处于等待状态

                try {

                    //try部分是具体需要执行的业务逻辑

                    if (IPUtils.checkConnected(route.getProducer().getLocalIp(), route.getProducer().getPort())

                            || IPUtils.checkConnected(route.getProducer().getNetIp(), route.getProducer().getPort())) {

                        routeSet.remove(route);

                    }

                } catch (Exception e) {

                    // XXX: handle exception

                    return;

                }

                cdAnswer.countDown(); // 任务执行完毕，cdAnswer减1。

            } catch (Exception e) {

                e.printStackTrace();

            }

        };

        executor.execute(runnable);// 为线程池添加任务

    }

    cdOrder.countDown();//-1

    cdAnswer.await();

} catch (Exception e) {

    // XXX Auto-generated catch block

    e.printStackTrace();

}

executor.shutdown();

注意：不要拿来做耗时的任务检测，这个线程池只适合短小快的任务处理。

欢迎关注我的个人公众号