当前位置: 首页 > news >正文

Java 并发-newFixedThreadPool

前言

为什么选择使用多线程?一种场景是在数据和业务处理能力出现瓶颈时,而服务器性能又有空闲,通常是cpu空闲,这时使用多线程就能很好的解决问题,而又无需加硬件,实际使用中,线程池又是最为常用的一种,本文介绍了newFixedThreadPool的使用方法

原理

newFixedThreadPool内部有一种阻塞队列,是一个无界的LinkedBlockingQueue,任务放在队列中,线程由线程池初始化创建好,如果有空闲线程,那么就调用去处理队列中的任务,没有就排队
需要注意的是这个队列可能会变得很大,要注意线程池的处理能力,避免排队任务太多造成内存溢出,其最大值是Integer的上限,不过由于是链表,也可以无限延长,或者可以在参数中显式创建有界阻塞队列,避免这个问题

实际使用

ExecutorService executor = Executors.newFixedThreadPool(num);

创建线程池,这里num是线程数量
然后这里做了一个循环模拟运行线程,注意最后要关闭线程池

  for (int i = 0; i < 10; i++) {
            executorService.execute(new Task(i));
        }
        executorService.shutdown();
        
 class Task implements Runnable {
    private int id;
 
    public Task(int id) {
        this.id = id;
    }
 
    public void run() {
        System.out.println("Task " + id + " is running...");
    }       

这种方法是execute方式,也可以使用submit方式,这两种方式区别在于
1,可以用Future对象获取submit的结果
2,execute()方法只能接受Runnable类型的任务,而submit()方法既可以接受Runnable类型的任务,也可以接受Callable类型的任务。
3,execute()方法是一种异步提交方式,即提交任务后立即返回,不会等待任务执行完成。而submit()方法是一种同步提交方式,即提交任务后会阻塞当前线程,直到任务执行完成。
4,而execute()方法没有提供取消任务的方法,submit()方法返回的Future对象可以用来取消任务
5,execute()方法中如果任务执行过程中发生了异常,则异常会被传递到任务提交的地方,并由任务提交的线程来处理。而submit()方法中,如果任务执行过程中发生了异常,异常将被封装在Future对象中,直到调用Future.get()方法时才会将异常抛出

优缺点

NFTP线程池优点在于使用简单,不需要手动的创建,管理,调度线程;同时由于线程数固定,不会出现超出导致系统崩溃,作为一个多线程的实现可以有效处理并发
缺点在于线程数固定,无法动态调整,同时暂存任务的阻塞队列长度无限拓展可能会造成内存耗尽,同时也无法控制任务时长,可能造成后续任务等待时间超长乃至失败,在笔者实际使用时,还发现这个线程池如果重复创建,可能会造成耗尽cpu资源,因为没有任务时长的控制,线程池执行过慢导致阻塞,这时即时手动interrupt依然会堆积线程,导致cpu执行过久无响应

相关文章:

  • 科技公司网站建设企业建站
  • php获取wordpress西安网站seo诊断
  • ps做网站画布多大长沙全网推广
  • 黄页推广是什么意思seo数据是什么
  • 北京海淀建设部邮编百度搜索优化软件
  • 百度网盟推广合作网站企业网站注册
  • Java——接口扩展
  • 记录一下移动端uView动态表单校验
  • 安装npm install element-plus --save报错
  • OpenCV 图形API(24)图像滤波-----双边滤波函数bilateralFilter()
  • 随机森林与决策树
  • 什么是虚拟线程?与普通线程的区别
  • python基础语法14-多线程与多进程
  • 校园智能硬件国产化的现状与意义
  • 使用层次聚类算法对wine数据集进行聚类分析
  • Flink的数据流图中的数据通道 StreamEdge 详解
  • 如何保持自己在职场的核心竞争力
  • Python贝叶斯回归、强化学习分析医疗健康数据拟合截断删失数据与参数估计3实例
  • icoding题解排序
  • NO.87十六届蓝桥杯备战|动态规划-完全背包|疯狂的采药|Buying Hay|纪念品(C++)
  • x265 编码器中运动搜索 ME 方法对比实验
  • C++基础精讲-03
  • 苍穹外卖总结
  • 【Web API系列】WebSocketStream API 深度实践:构建高吞吐量实时应用的流式通信方案
  • 23种设计模式生活化场景,帮助理解
  • 洛谷刷题Day1——P1706+P1157+P2089+P3654