IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> Java知识库 -> 彻底搞懂Java线程池 -> 正文阅读

[Java知识库]彻底搞懂Java线程池

为什么使用线程池?

反复创建线程开销大,可以复用线程池
过多的线程会占用太多的内存

解决以上问题的方法:

  • 用少量的线程,避免内存占用过多
  • 让这部分线程都保持工作,且反复执行任务,避免生命周期的损耗

线程池的好处:

加快响应速度,提高用户体验
合理利用CPU内存
统一管理

线程池使用的场合

服务器接受大量请求时,使用线程池技术是非常合适的,它可以大大减少线程的创建和销毁次数,提高服务器的工作效率。在实际开发中,如果创建5个以上 的线程,那么就可以使用线程池来管理线程。

创建和停止线程

线程池构造方法的参数?
线程池应该手动创建和自动创建那个更好?
线程池里的线程数量设置未多少合适?
停止线程的正确方法?

线程池构造函数的参数:

线程池构造函数的参数
corePoolSize: 核心线程数
线程池在完成初始化后,默认情况下,线程池中并没有任何线程,会等到有任务到来时再去创建新的线程去执行任务。
maxPoolSize:在核心线程的基础上,额外增加的线程数的上限。
在这里插入图片描述
根据图可知添加线程的规则:

1.如果线程数小于corePoolSize,即使其他工作线程处于空闲状态,也会创建一个新线程来运行任务。
2.如果线程数等于或大于corePoolSize但少于maximumPoolSize,则将任务放入队列。
3.如果线程池已满,并且线程数小于maxPoolSize,则创建一个新线程来运行任务。
4.如果队列已满,并且线程数大于或等于maxPoolSzie,则参数拒绝该任务。
添加线程规则
添加线程判断顺序:corePoolSize——workQueue——maxPoolSize

比如线程池的核心线程是5个,最大线程池大小为10个,队列为50个。
则线程池的请求最多会创建5个,然后任务将被添加到队列中,直到达到50。队列已满时,将创建最新的线程maxPoolSize,最多达到10个,如果再来任务就直接拒绝。

keepAliveTime:如果线程池当前的线程数多于corePoolSize,那么如果多余的线程空闲时间超过keepAliveTime,那么就会终止。

ThreadFactory:
默认使用Executors.defaultThreadFactory()
创建出来的线程都在同一个线程组。
如果自己指定ThreadFactory,那么就可以改变线程名、线程组、优先级、是否是守护线程等等。

常见的3中队列类型:
直接交接:SynchronousQueue
无界队列:LinkedBlockingQueue
有界队列:ArrayBlockingQueue

线程池应该手动创建和自动创建那个更好?

手动创建好,因为这样可以明确线程池的运行规则和避开资源浪费的风险。

  • newFixedThreadPool:容易造成大量内存占用,可能导致DOM
public class FixedThreadPoolTest  {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newFixedThreadPool(4);
        for (int i = 0; i < 500; i++) {
            executorService.execute(new Task());
        }
    }
}
class Task implements Runnable{

    @Override
    public void run() {
        try {
            Thread.sleep(500);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName());
    }
}
  • newSingleThreadExecutor:当请求堆积的时候,可能会占用大量内存。
//演示FixedThreadPool出错
public class FixedThreadPoolOOM {
    private static ExecutorService executorService = Executors.newFixedThreadPool(1);

    public static void main(String[] args) {
        for (int i = 0; i < Integer.MAX_VALUE; i++) {
            executorService.execute(new SubThread());
        }
    }
}
class SubThread implements Runnable{

    @Override
    public void run() {
        try {
            Thread.sleep(10000000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
  • newCachedThreadPool:弊端在于第二个参数maximumPoolSize被设置为了Integer.MAX_VALUE,这可能会创建数量非常多的线程,甚至导致DOM
  • newScheduledThreadPool:原因和newCachedThreadPool一样

常见的线程池:

FixedThreadPool

在这里插入图片描述

CachedThreadPool:可缓存线程池,具有自动回收多余线程的功能
在这里插入图片描述

ScheduledThreadPool:支持定时及周期性任务执行的线程池
SingleThreadExecutor:单线程的线程池只会用唯一的工作线程来执行任务
原理和FixedThreadPool一样,但是线程数量被设为1

四种线程池的构造方法的参数:
在这里插入图片描述
阻塞队列分析:
在这里插入图片描述

  Java知识库 最新文章
计算距离春节还有多长时间
系统开发系列 之WebService(spring框架+ma
springBoot+Cache(自定义有效时间配置)
SpringBoot整合mybatis实现增删改查、分页查
spring教程
SpringBoot+Vue实现美食交流网站的设计与实
虚拟机内存结构以及虚拟机中销毁和新建对象
SpringMVC---原理
小李同学: Java如何按多个字段分组
打印票据--java
上一篇文章      下一篇文章      查看所有文章
加:2021-09-29 10:06:28  更:2021-09-29 10:09:35 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/23 19:33:55-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码