(JAVA)-(多线程)-线程池

2023-12-29 14:49:13

线程池,顾名思义就是存放线程的池子,当有任务时能够随时取用线程,任务结束后能够放回线程池中。如果把线程比成碗,线程池就像一个碗柜一样。

使用线程池的好处:

1.当有大量线程对象时,减少了线程创建销毁造成的损耗。

2.提高响应速度

3.提高线程的可管理性

线程池的核心逻辑:

1.创建一个池子,池子是空的

2.提交任务的时候池子会创建新的线程对象,任务执行完毕,线程归还给池字,下次再提交任务时,不需要创建新的线程,直接复用已有的线程即可

3.提交任务时,池子中没有空闲的线程,也无法创建新的线程,任务就会排队

代码实现:

1.创建线程池

2.提交任务

3.所有的任务全部执行完毕,关闭线程

一:使用Executors工具类创建线程池对象

Executors是线程池的一个工具类,能调用他的静态方法创建线程池对象

public static ExecutorService newCachedThreadPool();
//创建一个没有上限的线程池
public static ExecutorService newFixedThreadPool(int nThreads);
//创建一个有上限的线程池

1.newCachedThreadPool() 方法:

能创建一个没有上限的线程池,如果现有任务没有线程进行处理,就会创建一个新线程并添加到缓存池中。如果有被使用完但是还没销毁的线程,就复用该线程。如果有线程60s未被使用的话就会从缓存中移出并终止(销毁)。因此,长时间保持空闲的线程池不会使用任何资源。

 ExecutorService pool1 = Executors.newcachedThreadPool();

提交任务:submit方法

可以看到submit方法参数可以传递runnable和Callable的实现类任务

public class test {
    public static void main(String[] args) {
        ExecutorService pool1 = Executors.newCachedThreadPool();
        pool1.submit(new MyRunnable());
        pool1.submit(new MyRunnable());
        pool1.submit(new MyRunnable());
//提交三个任务
        pool1.shutdown();
    }
}

 class MyRunnable implements Runnable {

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName()+"---"+i);
        }
    }
}

我们可以看到线程池创建了三个线程。

2.newFixedThreadPool(int num)方法

这个方法能创建一个固定线程数的线程池,超出线程任务数量的线程会在队列中等待,方法参数为线程池中的线程数

public class test {
    public static void main(String[] args) {
        ExecutorService pool1 = newFixedThreadPool(1);
        pool1.submit(new MyRunnable());
        pool1.submit(new MyRunnable());
        pool1.submit(new MyRunnable());
//提交三个任务
        pool1.shutdown();
    }
}

 class MyRunnable implements Runnable {

    @Override
    public void run() {
        for (int i = 0; i < 100; i++) {
            System.out.println(Thread.currentThread().getName()+"---"+i);
        }
    }
}

我们可以看到结果中只有线程1在执行任务。

二:自定义线程池

我们首先对Executors工具类进行跟进

我们发现创建这个线程池的方法在底层调用了一个 ThreadPoolExecutor类去创建了对象,并且传递了一些参数进去,ThreadPoolExecutor其实就是线程池的类。

我们先讲解线程池的运行流程

线程池中分为核心线程和临时线程。临时线程倘若经过了一定时间没有处理,就会进行销毁

当任务进行提交时,线程池便会创建线程。

倘若提交的任务数超过了核心线程数,就会在阻塞队列中进行等待,直到核心线程正在进行的任务完成后再执行。倘若提交的任务数超出了阻塞队列的长度,就会进入临时队列中进行执行,若提交的任务在超出了临时队列的范围,就会是使用任务拒绝策略拒绝任务。

通过以上,我们了解了线程池的运行流程。接着我们来看看线程池的参数

跟进发现,线程池这个类最长的构造方法有七个参数,我们逐个讲解

1.corePoolSize:这个参数就是线程池的核心线程数。

2.maximumPoolSize:这个参数是线程池的最大线程数,他肯定是大于核心线程数,从源码中也可以看到,如果这样做在运行时会抛出异常:IllegalArgumentException。

3.keepAliveTime:这个参数是空闲线程的等待时间,当超过这个时间临时线程还没有执行任务,临时线程就会销毁。

4.unit:这个是线程池的空闲时间的单位,需要调用TimeUnit中的枚举常量

  • 它在TimeUnit类中有7种静态属性可取。
    • 天:TimeUnit.DAYS;
    • 小时:TimeUnit.HOURS;
    • 分钟:TimeUnit.MINUTES;
    • 秒:TimeUnit.SECONDS;
    • 毫秒:TimeUnit.MILLISECONDS;
    • 微妙:TimeUnit.MICROSECONDS;
    • 纳秒:TimeUnit.NANOSECONDS;

5.workQueue:这个参数是线程在等待的阻塞队列,需要传递一个阻塞队列进去。

6.theadFactor:这个参数意思是线程工厂,用于创建新的线程。我们可以传递Executros工具类中的deafaultThread方法进行创建线程工厂,他在底层也是创建了一个线程。

7.rejectedExecutionHandler:这个是一个接口,代表任务的拒绝策略,在ThreadPoolExecutor中以内部类的方式内部类方式存在,他们都实现了rejectedExecutionHandler接口。

  • AbortPolicy:丢弃任务并抛出RejectedExecutionException异常。线程池默认的拒绝策略。如何使用new ThreadPoolExecutor.AbortPolicy()
  • DiscardPolicy:也是丢弃任务,但是不抛出异常。
  • DiscardOldestPolicy:丢弃队列最前面的任务,也就是队列头的元素,然后重新尝试执行任务(重复此过程)。如果此时阻塞队列使用PriorityBlockingQueue优先级队列,将会导致优先级最高的任务被抛弃。
  • CallerRunsPolicy:既不抛弃任务也不抛出异常,而是由调用线程的主线程来处理该任务。换言之就是由调用线程池的主线程自己来执行任务(例如:是有main线程启动的线程池,当触发次策略时,多余的任务就会交由main线程来执行),因此在执行任务的这段时间里主线程无法再提交新任务,从而使线程池中工作线程有时间将正在处理的任务处理完成,所以对性能和效率必然是极大的损耗。

那么线程池多大合适呢?

要理解上面的公式,我们得先了解最大并行数是什么

四核八线程:代表着电脑有四个大脑 ,能同时干四件事情,而超线程技术,把一个物理核心模拟成两个逻辑核心,理论上要像八颗物理核心一样在同一时间执行八个线程,所以电脑最大并行数为8.

我们可以用RunTime工具类中的availiableProcessors()静态方法去获取java能够使用的最大线程数。

项目运算比较多,读取本地文件或者数据库比较少,就属于cpu密集型运算,反之则属于IO密集型运算

第一个公式很容易能看懂,那么第二个公式是什么意思呢?

举个例子:从本地文件中读取两个数据,相加。假设java能使用的最大并行数为8,读取数据用了1秒,cpu计算相加用了1秒

从本地文件中读取数据并不是cpu干的事,cpu计算相加用了一秒,因此最合适的线程池大小就是

文章来源:https://blog.csdn.net/fdvvg/article/details/135239274
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。