线程池

2022-02-09 本文已影响0人双囍_小赵

线程饥饿：多任务混合在同一池中，如果出现互相影响的状况出现类似死锁的问题。

例如：在一个线程池中，开辟两个线程，执行做菜和上菜这两个功能，做菜和上菜有先后顺序的，所以如果一个线程在前面执行上菜就不太行，这就会造成线程饥饿；

· 以上情况解决方法：

当有两个相关联的任务在同一线程池中，这时就需要重新开辟一个线程池，来处理其中一个任务，分开两者，避免造成饥饿状态。

Android中可以将没有相关联的、没有延迟、速率上大概一致的任务，可以做一个统一的线程池去做处理。

一个线程的开启消耗：

线程开启在JVM中就会有1M的栈空间，需要上下文，需要在高速缓存中暂存；

创建多少个线程合适

一个线程池创建的线程数量计算公式：

 线程数 = cpu核数 * 期望cpu的利用率 * 总时间（cpu计算时间+等待时间）/ cpu计算时间；
cpu核数：假如是4核；
期望cpu最大利用率：100%；
cpu计算时间：就是手机在运行任务的时间；
等待时间：在服务端返回请求数据的时间；

计算：4 * 100% * 100%（假设总时间为100%）/ 50%（计算时间是50%） = 8

线程池执行

public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue,
                              ThreadFactory threadFactory) {
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             threadFactory, defaultHandler);
    }

maximumPoolSize：最多的线程数量；
corePoolSize：核心线程数；
keepAliveTime：表示急救线程的生存时间；
unit：急救线程的时间单位；
应急线程数量 = maximumPoolSize - corePoolSize；

有任务的情况下会根据线程池的状态进行处理：

线程池状态：

Running：正在运行；
Shutdown：线程池停止接受任务，但是会将已有的任务完成；
Stop：停止接受任务，并且将线程池中的任务抛弃；
Tidying：任务执行完毕，活动线程将为0即将进入终结；
Terminated：终结状态；

在整体的线程池中，状态和核心线程数会被多线程使用，所以都要使用原子数据记录，将二者进行合并成同一个变量：
private final AtomicInteger ctl = new AtomicInteger(ctlOf(RUNNING, 0));

利用位运算合并两个原子变量的意义：如果两个都是原子变量，合并之后只需要对一个原子进行CAS操作，不需要再操作两个CAS。

ThreadPoolExecutor本身自己提供了四种拒绝策略：

CallerRunsPolicy：在任务被拒绝后，会使用当前线程池所在的线程去执行被拒绝的任务，这个策略的缺点就是会造成主线程阻塞；
AbortPolicy：默认拒绝策略，会抛出一个异常，也不执行这个任务了；
DiscardPolicy：什么都不做；
DiscardOldestPolicy：会抛弃线程池中最先添加进来的任务，把这个新任务添加进去；

ThreadPoolExecutor和自定义线程的区别：

1.急救线程：提升性能（消耗了一点空间，会及时消耗）
2.状态设置：对线程池的管理
3.原子合并：利用位运算进行CAS优化
4.工厂模式：  
    //缓存线程池
        /**
         * 缓冲线程池，急救线程无限扩展
         * 急救线程销毁条件1分钟
         * 这种线程池使用最好是自己去做，这个无限容易崩
         */
        ExecutorService executorService = Executors.newCachedThreadPool();

        //单个线程
        ExecutorService singe = Executors.newSingleThreadExecutor();

        //固定线程池
        ExecutorService fix = Executors.newFixedThreadPool(5);

        //定时线程池
        ScheduledExecutorService schdule = Executors.newScheduledThreadPool(5);

线程池