线程池总结

忘是亡心i 2022-06-13 06:26 195阅读 0赞

java线程池是为了防止内存溢出，而不是为了加快效率。使用java线程池也应该设置合理的线程数量。

### 为什么要用线程池 ###

1、可以减少创建和销毁线程的次数，这样每个工作线程都可以被重复利用，当一个新任务需要运行时，如果线程池中有等待的工作线程可以直接运行，否则进入等待队列。  
2、可以根据系统的承受能力，调整线程池中工作线程的数目，防止因为消耗过多的内存，而把服务器累趴下(每个线程需要大约1MB内存，线程开的越多，消耗的内存也就越大，最后死机)。

###    总结 ###

线程池里的线程可以复用的

Executors.newFixedThreadPool(5);//开启固定线程数量的线程池
    Executors.newCachedThreadPool();//开启缓存线程池，大概60s就会被回收
    Executors.newSingleThreadPool();//线程池里只有一个线程，保证所有的任务顺序执行
    Executors.newScheduledThreadPool(4);//定时器线程池，替代Timer

public static void testTimer1() {
        ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
        pool.scheduleWithFixedDelay(new Thread(() -> {
            //定时打印时分秒
            LocalTime now = LocalTime.now();
            LocalTime dateTime = now.withNano(0);
            System.out.println(dateTime);
        }), 2, 1, TimeUnit.SECONDS);
    }

这个定时任务一旦执行起来就会没完没了，可以通过关闭线程池来阻止继续执行，如下所示

public static void testTimer2() {
        ScheduledExecutorService pool = Executors.newScheduledThreadPool(1);
        pool.scheduleWithFixedDelay(new Thread(() -> {
            Integer integer = Integer.valueOf(RandomNumUtil.random4());
            System.out.println(integer);
            if (integer > 5000) {
                pool.shutdown();
            }
    
        }), 2, 1, TimeUnit.SECONDS);
    }

对比以下的写法

public static void testTimer3() {
        final ScheduledExecutorService service = Executors.newSingleThreadScheduledExecutor();
        // 第二个参数为首次执行的延时时间，第三个参数为定时执行的间隔时间
        service.scheduleAtFixedRate(new Runnable() {
            public void run() {
                Integer integer = Integer.valueOf(RandomNumUtil.random4());
                System.out.println(integer);
                if (integer > 5000) {
                    service.shutdown();
                }
            }
        }, 2, 1, TimeUnit.SECONDS);
    }

### ExecutorService ###

ExecutorService扩展了Executor并添加了一些生命周期管理的方法。一个Executor的生命周期有三种状态：运行，关闭，终止。Executor创建时处于运行状态。

线程池的关闭调用ExecutorService.shutdown()；

判断线程池是否已关闭，IsTerminated返回true表示已关闭。

如果Executor处于关闭状态，往Executor提交任务会抛出unchecked exception RejectedExecutionException.

### 其他api ###

ForkJoinPool pool = new ForkJoinPool()后台线程需要打印System.in.read(),分叉合并，应用场景是大规模数据运算，把任务切分，递归算法。

ThreadPoolExecutor线程池通用类，可以自定义线程池，以上底层大多也是使用这个类

Future 是executorservice.submit()的返回值，future.get()如果任务没执行完会阻塞，FutureTask包装Callable或Runnable。

参考：[Java线程池 ExecutorService][Java_ ExecutorService]

[Java_ ExecutorService]: http://blog.csdn.net/suifeng3051/article/details/49443835