一文读懂Java线程池之线程复用原理

本文主要是介绍一文读懂Java线程池之线程复用原理，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

什么是线程复用

在Java中，我们正常创建线程执行任务，一般都是一条线程绑定一个Runnable执行任务。而Runnable实际只是一个普通接口，真正要执行，则还是利用了Thread类的run方法。这个rurn方法由native本地方法start0进行调用。我们看Thread类的run方法实现

    /* What will be run. */private Runnable target;/*** If this thread was constructed using a separate* <code>Runnable</code> run object, then that* <code>Runnable</code> object's <code>run</code> method is called;* otherwise, this method does nothing and returns.* <p>* Subclasses of <code>Thread</code> should override this method.** @see     #start()* @see     #stop()* @see     #Thread(ThreadGroup, Runnable, String)*/@Overridepublic void run() {if (target != null) {target.run();}}

很明显，Thread类的run方法就是使用构造Thread类传入来的Runnable对象，执行Runnable的run方法。这样可以很好的将任务和Thread类解耦，如果继承Thread类再去重写run方法当然也是可以，但却耦合了，并且Java是单继承，所以继承Thread类这种方式通常不会使用，没有任何好处。

现在问题是，一个线程只能执行一个Runnable对象，那么这条线程它就是不能复用的，完成任务它就该Terminated了。如果系统任务很多，频繁创建线程带来的开销大，线程数量不可控导致系统处于一种不安全的状况，系统随时可能被大量线程搞跨，于是线程池就出现了。线程池要解决的问题就是用少量线程处理更多的任务，这样一来，线程池首先要实现的就是线程复用。不能说还是一条线程只处理一个Runnable任务，而是一条线程处理无数Runnable任务。最容易想到的方案就是将Runnable对象放到队列中，在Thread类的run方法中不断从队列中拉取任务执行，这样一来就实现了线程复用。当然，实际线程池也差不多是这么干的，下面我们详细看一下线程池实现线程复用的原理。

线程池处理任务的过程

在线程池原理解析1中有详述线程池创建线程及处理任务的过程。这里再次简单看一下流程图以方便理解下面的线程复用原理解析。

 线程复用原理解析

线程处理任务过程源码解析

首先我们看看线程池是怎么使用的

import cn.hutool.core.thread.ThreadFactoryBuilder;import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;/*** @author kangming.ning* @date 2023-02-24 16:27* @since 1.0**/
public class CustomThreadPool1 {private static ThreadFactory threadFactory = new ThreadFactoryBuilder().setNamePrefix("线程池-").build();private static ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(Runtime.getRuntime().availableProcessors(),Runtime.getRuntime().availableProcessors() * 2,60L,TimeUnit.SECONDS,new LinkedBlockingQueue<>(10),threadFactory, new ThreadPoolExecutor.CallerRunsPolicy());public static void main(String[] args) throws InterruptedException {Runnable r = () -> {System.out.println(Thread.currentThread().getName() + " is running");};for (int i = 0; i < 35; i++) {Thread.sleep(1000);threadPoolExecutor.submit(r);}}}

可见，threadPoolExecutor的sumit方法就是用来提交任务的，于是，从这个方法开始分析源码，把源码的关注点放在线程复用部分。

    /*** @throws RejectedExecutionException {@inheritDoc}* @throws NullPointerException       {@inheritDoc}*/public Future<?> submit(Runnable task) {if (task == null) throw new NullPointerException();RunnableFuture<Void> ftask = newTaskFor(task, null);execute(ftask);return ftask;}

第一句只是用来包装一下有返回值的任务

这篇关于一文读懂Java线程池之线程复用原理的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---