线程池

作者: 双囍_小赵 | 来源:发表于2022-02-09 21:06 被阅读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);

相关文章

  • java线程池

    线程VS线程池 普通线程使用 创建线程池 执行任务 执行完毕,释放线程对象 线程池 创建线程池 拿线程池线程去执行...

  • java----线程池

    什么是线程池 为什么要使用线程池 线程池的处理逻辑 如何使用线程池 如何合理配置线程池的大小 结语 什么是线程池 ...

  • Java线程池的使用

    线程类型: 固定线程 cached线程 定时线程 固定线程池使用 cache线程池使用 定时调度线程池使用

  • Spring Boot之ThreadPoolTaskExecut

    初始化线程池 corePoolSize 线程池维护线程的最少数量keepAliveSeconds 线程池维护线程...

  • 线程池

    1.线程池简介 1.1 线程池的概念 线程池就是首先创建一些线程,它们的集合称为线程池。使用线程池可以很好地提高性...

  • 多线程juc线程池

    java_basic juc线程池 创建线程池 handler是线程池拒绝策略 排队策略 线程池状态 RUNNIN...

  • ThreadPoolExecutor线程池原理以及源码分析

    线程池流程: 线程池核心类:ThreadPoolExecutor:普通的线程池ScheduledThreadPoo...

  • 线程池

    线程池 [TOC] 线程池概述 什么是线程池 为什么使用线程池 线程池的优势第一:降低资源消耗。通过重复利用已创建...

  • java 线程池使用和详解

    线程池的使用 构造方法 corePoolSize:线程池维护线程的最少数量 maximumPoolSize:线程池...

  • 线程池

    JDK线程池 为什么要用线程池 线程池为什么这么设计 线程池原理 核心线程是否能被回收 如何回收空闲线程 Tomc...

网友评论

      本文标题:线程池

      本文链接:https://www.haomeiwen.com/subject/qukczltx.html