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

线程池的应用

1.线程的执行机制

  • 线程分为用户线程 和 内核线程

    • 内核线程就是系统级别的线程,与cpu逻辑处理器数量对应的

    • 用户线程就是使用java代码创建的Thread对象

  • 用户线程必须与内核线程关联(映射),才能执行任务

  • 当用户线程多于内核线程时,内核线程就需要不停的上下文切换,使得多个用户线程都能得以执行

  • 上下文会影响性能,消耗资源。

  • 大量的创建用户线程,消耗用户线程,也会影响性能,消耗资源。

  • 所以我们希望,创建合适数量的线程,不要频繁的创建新线程和销毁线程,希望创建的线程可以反复利用

  • 我们就可以使用池化技术:线程池。

2.线程池的执行机制

  • 线程池是jdk1.5中 JUC提供的一个工具

  • 线程池的作用可以统一的创建,分配,管理,销毁线程。实现线程的复用。

3.线程池的应用

3.1拥有线程池

有两种方式,可以拥有线程池对象

  1. 手动创建线程池对象,需要传递7个参数

    JUC提供了3个可以创建线程池的类,我们最常用的就是ThreadPoolExecutor

  2. 通过JUC提供的工具类,快速获得线程池对象 (别人帮我们创建)

    JUC提供了一个Executors工具类,该工具类提供了5个静态方法,可以快速获得对象

3.2手动创建线程池(7个参数)

有4种重载方法

①需要5个参数      ②需要6个参数   5+a      ③需要6个参数   5+b      ④需要7个参数

1.  int corePoolSize : 核心线程数 , 池内线程数的下限,未达下限,优先创建新线程。达到下限,任务装入队列

2.  int maximumPoolSize : 最大线程数。队列满,创建更多线程,直到达到上限。拒绝任务

3.  long keepAliveTime : 线程空闲存活时间(数字)

4.  TimeUnit unit : 配合keepAliveTime , 指定存活时间(单位)

5.  BlockingQueue<Runnable> workQueue : 任务等待队列(阻塞队列)
                                    ArrayBlockingQueue ,底层数组,适合指定长度
                                    LinkedBlockingQueue,底层链表,适合无限长度
                                    DelayQueue , 适合延迟(定时)任务
                                    PriorityBlockingQueue  自认队列(元素自然有序,大小)
                                    SynchronousQueue 同步队列,只能存一个元素

6.  ThreadFactory threadFactory : 线程工厂,在线程池内部用来创建线程的。可以自定义

7.  RejectedExecutionHandler handler : 拒绝策略,当任务队列满,线程达到上下且都忙碌,新任务被拒绝
                                    juc提供了多种拒绝策略,也可以自定义
                                    AbortPolicy  拒绝任务,并抛出异常
                                    DiscardPolicy 拒绝任务,没有任何提示
                                    DiscardOldestPolicy 拒绝最总加入等待瑞列的任务,
                                                        新任务加入队列
                                    CallerRunsPolicy 拒绝任务,将任务交还给发起任务的线程

ThreadPoolExecutor pool=new ThreadPoolExecutor(5,10,5, TimeUnit.MICROSECONDS,new ArrayBlockingQueue(10));pool.execute(Runnable); //执行Runnable任务
pool.submit(Runnable); //获得Future对象,可以知道线程是否执行完毕,但无法获得返回值
pool.submit(Callable); //获得Future对象,可以知道线程是否执行完毕,也可以获得返回值
future.isDone();//快速获得boolean结果,用来判断任务是否执行完毕
future.get();//获得任务执行的结果,如果还没有执行完毕,当前线程会处于等待状态
pool.getPoolSize();//获得线程数
pool.prestartAllCoreThreads() ;//预先创建核心数量的线程
pool.allowCoreThreadTimeOut(true);//设置核心数量的线程也可以超时被销毁
Queue q = pool.getQueue();//获得任务队列
q.size(); //等待执行的任务数量
q.clear();
q.add();
q.remove();

http://www.lryc.cn/news/433811.html

相关文章:

  • OPenCV结构分析与形状描述符(5)查找图像中的连通组件的函数connectedComponents()的使用
  • HCIA--实验十三:VLAN间通信子接口实验/双单臂路由实验
  • AIStarter市场指南:项目分享与框架优化【AI绘画、写作、对话、办公、设计】
  • 机器学习第8章 集成学习
  • 京东鸿蒙上线前瞻——使用 Taro 打造高性能原生应用
  • day2 QT
  • JS_函数声明
  • 快速排序+归并排序代码回顾
  • DBC中一种特殊的特殊的Signal—多路复用Signal
  • 前端基础面试题·第三篇——JavaScript(其三)
  • MacBook真的不能打游戏吗?Mac打游戏会损坏电脑吗?苹果电脑怎么玩游戏
  • 安卓逆向(之)真机root(红米手机)
  • 关于转行网络安全的一些建议
  • (六十五)第 10 章 内部排序(希尔排序)
  • 802.11 中 scrambler的matlab仿真
  • centos 服务器 多网卡 ip 地址 设置
  • 什么是大数据、有什么用以及学习内容
  • ZBrush与Blender雕刻功能哪个更好些?
  • 软件工程技术专业软件开发综合实训室解决方案
  • 链动2+1:高效用户留存与增长的商业模式解析
  • Python 调用手机摄像头
  • E5053A 微波下变频器
  • 记录:uniapp直播的弹幕的样式修改与发送弹幕会自动滚动到底部两个技巧
  • 【流程设计】JAVA系统集成activiti工作流,流程设计器,在线审批,会签,驳回,流程图查看(实际多套系统运用案例分析)
  • Debezium系列之:大规模应用debezium server采集数据库,从每个Debezium Server中导出JMX采集指标
  • QY-SW 浮子水位计 RS485 LCD显示屏
  • 橘子学ES实战操作之管道类型Ingest pipelines的基本使用
  • VScode:前端开发中的常用快捷键和技巧
  • Radmin-同一局域网只需IP就可以控制电脑
  • 【附答案】C/C++ 最常见50道面试题