Java线程池浅谈
Java线程池浅谈
人头马没面 发表于8个月前
Java线程池浅谈
  • 发表于 8个月前
  • 阅读 3
  • 收藏 0
  • 点赞 0
  • 评论 0

【腾讯云】买域名送云解析+SSL证书+建站!>>>   

今天来谈一谈Java线程池如何“归还”线程,大家都知道数据库连接池使用完成后需要将连接还回连接池。Java线程池中的线程使用完后需不需要归还,如何归还呢,想了半天没想明白,看了JDK源代码后搞明白了。

核心代码都在ThreadPoolExecutor类里。

首先创建线程池时,设置corePoolSize、maximumPoolSize。意思很明白,不多解释。

然后当调用线程池的execute方法时,如果当前线程池里的线程数比corePoolSize小,则直接创建一个新的线程,这个地方有个巧妙的处理,并不是直接new Thread,而是创建一个Worker对象。

Worker类实现了Runnable接口,如下图所示:

private final class Worker
    extends AbstractQueuedSynchronizer
    implements Runnable

并持有一个Thread对象,该Thread对象包装了Worker的Runnable接口,如下图所示:

Worker(Runnable firstTask) {
    setState(-1); // inhibit interrupts until runWorker
    this.firstTask = firstTask;
    this.thread = getThreadFactory().newThread(this);
}

Worker的run方法如下:

/** Delegates main run loop to outer runWorker  */
public void run() {
    runWorker(this);
}
final void runWorker(Worker w) {
    Thread wt = Thread.currentThread();
    Runnable task = w.firstTask;
    w.firstTask = null;
    w.unlock(); // allow interrupts
    boolean completedAbruptly = true;
    try {
        while (task != null || (task = getTask()) != null) {
            w.lock();
            // If pool is stopping, ensure thread is interrupted;
            // if not, ensure thread is not interrupted.  This
            // requires a recheck in second case to deal with
            // shutdownNow race while clearing interrupt
            if ((runStateAtLeast(ctl.get(), STOP) ||
                 (Thread.interrupted() &&
                  runStateAtLeast(ctl.get(), STOP))) &&
                !wt.isInterrupted())
                wt.interrupt();
            try {
                beforeExecute(wt, task);
                Throwable thrown = null;
                try {
                    task.run();
                } catch (RuntimeException x) {
                    thrown = x; throw x;
                } catch (Error x) {
                    thrown = x; throw x;
                } catch (Throwable x) {
                    thrown = x; throw new Error(x);
                } finally {
                    afterExecute(task, thrown);
                }
            } finally {
                task = null;
                w.completedTasks++;
                w.unlock();
            }
        }
        completedAbruptly = false;
    } finally {
        processWorkerExit(w, completedAbruptly);
    }
}

Worker的run方法执行时会从一个队列里获取Runnable接口的实现,即上图的getTask方法,获取到后执行task的run方法。

核心部分都已经展示完了,让我们把他们串联起来。

线程池的execute方法执行时创建一个Worker,然后执行Worker持有的线程的start方法,其实也就是启动了一个线程。该线程执行Worker的run方法,因为Worker也实现了Runnable接口。run执行时首先从队列获取任务,有的话就执行其run方法,不是start方法,所以并没有新启动线程。该线程执行完成后,如果队列中有任务,那么该线程会继续执行新的任务,实现了线程复用。

所以线程池里的线程并不需要显式归还。

 

  • 打赏
  • 点赞
  • 收藏
  • 分享
共有 人打赏支持
粉丝 3
博文 1
码字总数 595
×
人头马没面
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: