Java教程

一文搞懂Java自定义线程池参数

本文主要是介绍一文搞懂Java自定义线程池参数,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!

背景:

线程是一个开发经常使用的东西,但是实际工作中很少有新建一个线程去执行任务,线程的创建和销毁都会耗费资源,我们一般都会用线程池来完成线程的创建和销毁。

  • 多说一句

JDK自带的线程池不建议大家去使用,每个都存在资源的浪费,甚至会引发OOM问题,大家都是开发,这些东西还是自己根据实际业务去创建自定义的好。

正文

  • 自定义一个线程池首先我们需要知道它怎么去构建,怎么传参,参数都是什么含义,参数传多少合适,接下来一一解开疑惑。
  • 我们首先看一下线程池的构造函数,分析一下里面的参数:

线程池构造函数

  1. CorePoolSize(核心线程数):
    就是我们经常去处理的任务的线程数量,线程池如果没有任务处理时,它们是在空闲状态,不会被销毁,有任务时,它们会直接去处理任务,如果忙不过来就会把任务添加到阻塞队列。

  2. MaximumPoolSize(最大线程数):
    上面说到核心线程来不及去处理任务,线程会放到队列中等待处理。当队列满了,没有办法继续缓存任务时,这个时候线程池会创建一个新线程去处理任务,注意:这里不是处理来的新任务,而是从队列头部拉一个出来,新任务放进去队列里面等待处理,大家都是有顺序的。
    当然这时候队列还是满的,如果任务过来还是会触发这个机制,去建新线程,这个参数就是控制可以创建的最大线程树,如果线程数量超过时,就会触发拒绝策略,下面会将。

  3. keepAliveTime(最大存活时间):
    刚才说了,如果核心线程数都忙着呢,队列也满了,我们就会创建新线程,可是如果线程都执行完任务总不能都去空闲不销毁吧。这时候肯定有一种机制去管理它们,如果空闲线程数大于核心线程数,它们多的线程最多活的时间根据这个参数来设置,到时间了,就会被销毁。

  4. Unit(单位):
    最大存活时间的单位。

  5. workQueue(阻塞队列):
    队列的作用你一定还记得,核心线程忙的时候,任务会放到队列中,JDK提供了4个队列供我们选择

    ArrayBlockingQueue: 基于数组的有边界的队列,按照先进先出排列,跟我们排队一个意思,不能插队。我们创建这个队列的时候,传一个参数就可以了,参数表示队列的容量大小。
    在这里插入图片描述
    LinkedBlockingQuene: 基于链表的阻塞队列,也是采用先进先出,创建时如果构造函数不传队列容量大小时,默认大小为Integer.Max,也可以指定容量大小。
    在这里插入图片描述
    在这里插入图片描述
    SynchronousQueue: 不缓存任务的阻塞队列,任务来了以后不会缓存到队列中,直接创建一个新线程去处理任务。
    在这里插入图片描述
    PriorityBlockingQueue: 是一个支持优先级的无界阻塞队列,直到系统资源耗尽。默认情况下元素采用自然顺序升序排列。也可以自定义类实现compareTo()方法来指定元素排序规则,或者初始化PriorityBlockingQueue时,指定构造参数Comparator来对元素进行排序。
    在这里插入图片描述

  6. ThreadFactory(线程工厂):
    通过ThreadFactory的newThread方法,可以对创建的线程做一些操控,ThreadFactory是一个接口,我们需要实现它的newThread的方法,这时候我们就可以设置一些线程的参数,这个参数可不填,有默认的。

  7. handler :拒绝策略:
    当队列满了时且线程数达到最大线程数时,这时候任务再来时,就会触发拒绝策略来应对接下来的任务,这时候肯定是资源不够用了,我们需要根据实际场景去选择正确的策略。JDK提供了4钟拒绝策略,我们来看一下每一个策略。
    AbortPolicy: 丢弃任务并抛出RejectedExecutionException异常。这是线程池默认的拒绝策略,在任务不能再提交的时候,抛出异常,及时反馈程序运行状态。如果是比较关键的业务,推荐使用此拒绝策略,这样子在系统不能承载更大的并发量的时候,能够及时的通过异常发现。
    DiscardPolicy: 丢弃任务,但是不抛出异常。如果线程队列已满,则后续提交的任务都会被丢弃,且是静默丢弃。
    DiscardOldestPolicy: 丢弃队列最前面的任务,新任务加到队列里面,如果有新任务过来,继续这个策略。
    CallerRunsPolicy: 如果队列满了,这个任务由调用线程去执行。

实战

public static void main(String[] args) {
	//阻塞队列
	ArrayBlockingQueue arrayBlockingQueue = new ArrayBlockingQueue<>(200);
	//新建一个自定义线程池
	ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(5, 50, 30, TimeUnit.SECONDS, arrayBlockingQueue);
	//循环输出数字
	for(int i =0;i<200;i++){
		int num = i;
		//submit执行方法,也可以用execute,submit具有返回值
		threadPoolExecutor.submit(new Runnable() {
			@Override
			public void run() {
				try {
					//让子弹飞一会儿
					Thread.sleep(1000);
					//输出线程名
					System.out.println(num +Thread.currentThread().getName());
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
		});
	}
	//线程池使用完一定要关闭
		threadPoolExecutor.shutdown();
	}
  • 输出结果
1pool-1-thread-2
2pool-1-thread-3
3pool-1-thread-4
0pool-1-thread-1
4pool-1-thread-5
5pool-1-thread-2
7pool-1-thread-4

注意点

  • 核心线程数多少合适?
    如果是计算性任务,不涉及I/O操作,使用CPU资源比较多,这时候核心线程数和CPU核数相同,
    如果是I/O比较多,比如批量下载文件,读写数据库、redis缓存,这些I/O操作用线程池就可以优化空间很大,我们把核心线程数设置为核数的double(双倍)。

  • 线程池启动方法:
    示例中使用的submit方法,submit方法可以接收Runnable和Callable,Callable可以有返回值,让我们可以知道线程池的执行情况。也可以用execute执行方法,可以启动线程池但是没有返回值。

  • 线程池关闭方法:
    线程池使用完,一定要关闭,这里有两个方法,shutdown()和shutdownNow(),前者是需要等待线程池执行完所有任务在关闭,后者正在执行的任务停止,没有执行的任务返回。

这篇关于一文搞懂Java自定义线程池参数的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!