线程
是操作系统能够进行运算调度的最小单位。它被包含在进程之中,是进程中的实际运作单位。
查看进程:pslist或 tasklist
查看进程下的线程:pslist -dmx pid号(需要安装PsTools)
池化技术
把一些能够复用的东西(比如说数据库连接、线程)提前放到池中,使用时从池子里取,用完了再放回池子中。避免重复创建、销毁的开销,从而极大提高性能。
看到这个池那个池的也不用蒙,一定是为了复用某些资源。
总之池子是存放东西、管理东西的,池子就是一种容器。
线程池简介
刚才也简单介绍了线程的概念,为什么要引入线程池呢?要讲到线程的生命周期,每个线程都有“创建——使用——销毁”这样一个大致的周期,创建、销毁都是要耗费资源的(时间、cpu等),线程数越多,耗费的资源越多。但我们又不得不使用多线程,那么线程池就出现了,解决了处理短时间内创建和销毁线程代价较大的弊端。
java线程池分类
实操
newFixedTheadPool是六种常用线程池的其中一种,newFixedThreadPool的特点是他的核心线程数和最大线程数是一致的,并且是一个固定线程数的线程池。线程池的大小一旦达到最大值后,再有新的任务提交时则放入无界阻塞队列中,等到有线程空闲时,再从队列中取出任务继续执行。
public class CalaulationStudentsData implements Runnable{ //学生数量 int studentNumber; //锁存器 CountDownLatch latch; @Override public void run() { try { //计算学生学习数据的方法 this.CalculationStudentData(); //计数器减一 latch.countDown(); }catch (Exception e){ throw new RuntimeException("学生进入学校执行数据异常"+e); } } /** * @Author:Guoyuan.Zhao * @Description:构造函数中传入学生的id * @CreateTime: 2022/12/30 9:38 * @param: [studentNumber, latch] * @return: **/ public CalaulationStudentsData(int studentNumber, CountDownLatch latch){ this.studentNumber=studentNumber; this.latch=latch; } /** * @Author:Guoyuan.Zhao * @Description:计算学生数据的方法 * @CreateTime: 2022/12/30 9:40 * @param: [] * @return: void **/ private void CalculationStudentData() throws InterruptedException { //输出学生编号和执行该任务的线程名称 Thread.sleep(100); System.out.println("学生" + studentNumber+"进入学校" + "接待的老师id(用到的线程号)" + Thread.currentThread().getId()); } }
public class threadPool { public static void main(String[] args) { long startTime=System.currentTimeMillis(); //获取开始时间 //实例化一个固定大小为10个线程的newFixedThreadPool线程池 ExecutorService excutorService = Executors.newFixedThreadPool(20); //构造CountDownLatch传入数量为100,初始化的计数器大小为100,与学生数量对应。 final CountDownLatch latch = new CountDownLatch(100); //计算100个学生进入学校的情况 for (int i = 0; i <100 ; i++) { excutorService.submit(new CalaulationStudentsData(i,latch));//线程提交任务 } try{ latch.await(); //使调用该方法的主线程处于等待状态,当倒数到0时主线程才执行。 } catch (InterruptedException e) { throw new RuntimeException("学生进入学校多线程处理异常",e); }finally { excutorService.shutdown();//关闭线程池 } long endTime=System.currentTimeMillis(); //获取结束时 System.out.println("程序运行时间: "+(endTime-startTime)+"ms"); } }
性能对比
运行前:
运行中:不使用线程池(100个线程)
运行中:使用线程池(10个线程)