简洁之美-java5线程池源码赏析（下）

简洁之美-java5线程池源码赏析（下）

            by  davy

在上篇中，大家了解线程池对线程的控制，本篇将重点介绍线程是如何被复用的。其实关键就在于，addIfUnderCorePoolSize（command）和addIfUnderMaximumPoolSize(command)新建立的线程会不停地从缓冲队列里获取待执行的任务并执行。只要线程池的缓冲队里有任务，线程就不会消亡，就会得到复用。缓冲队列里没有待处理的任务，并且线程超过了预定义的允许空闲时间，线程就会消亡。接下来看一下addIfUnderCorePoolSize（Runnable command）方法，其代码如下：

privateboolean addIfUnderCorePoolSize(Runnable firstTask)

{

        Thread t = null;

        final ReentrantLock mainLock = this.mainLock;

        mainLock.lock();

        try

{

            if (poolSize < corePoolSize && runState == RUNNING)

                t = addThread(firstTask);

        } finally

 {

            mainLock.unlock();

        }

        if (t == null)  returnfalse;

        t.start();

        returntrue;

 }

简单地说，就是先建立线程，并启动线程。我们关心的是线程启动后，其执行的任务时什么。addThread(firstTask)的代码如下：

private Thread addThread(Runnable firstTask)

{

        Worker w = new Worker(firstTask);

        Thread t = threadFactory.newThread(w);

        if (t != null) {

            w.thread = t;

            workers.add(w);

            int nt = ++poolSize;

            if (nt > largestPoolSize)

                largestPoolSize = nt;

        }

        return t;

 }

Worker是一个内部类，是对真正要执行的任务的包装。Thread t = threadFactory.newThread(w);其实就是新建立了一个Thread实例t，并使该线程t的target=W(即Worker).这样当线程t启动后，Worker.run()会执行。下面就来看一下Worker的真面目吧，代码如下（限于篇幅只贴关键代码）：

        publicvoid run()

 {

            Try

 {

                Runnable task = firstTask;

                firstTask = null;

                while (task != null || (task = getTask()) != null)

{

                    runTask(task);

                    task = null;

                }

            } finally

{

                workerDone(this);

            }

        }

    重点就是while循环，当前处理的任务不为null就执行当前的任务；如果当前处理的任务是null就从线程池的缓冲队列里获取任务来执行。getTask()其实就是从缓冲队列取出任务，不再详细介绍。也就是说，只要缓冲队列里还有待处理的任务，Worker的run()方法就会执行下去，而执行Worker的Thread实例t就不会空闲，不会消亡。这样线程就得到了复用。

    篇后语：

    高手就是高手，顶级高手的代码没有过多的华丽，其朴素、精炼、简洁令人叹为观止。JDK中随处可见顶级高手的代码，不妨观摩拜读。在jdk1.5线程池的代码中，没有Synchronized关键字，用的都是Lock和同步(阻塞)队列,因为后者的性能更优。在下才疏学浅，生怕粗俗肤浅的理解会亵渎高手的代码。因此，文中不当之处，恳请大家批评指正，不胜感激。