JDK 5.0 自带线程池学习

根据《精通Spring企业应用开发详解》中Concurrent章节整理。

 

了解JDK1.5的Executor

 

    java.util.concurrent.Executor 接口主要目的是将“任务提交”和“任务执行”两者分离解耦。该接口定义了任务提交的方法，实现者可以提供不通的任务运行机制，解决具体的线程使用规则、调度方式等。

   

    Executor 只有一个方法：void execute（Runnable cmd），它接受实现了Runnable接口的实例，该实例代表了一个需要执行的任务。调用者可以通过如下伪代码提交任务：

       

 

Executor exe = anExecutor;

exe.execute(new RunnableTask01()); // 任务一

exe.execute(new RunnableTask02()); // 任务二

 

备注：通过线程池统一管理不通任务的执行。

 

    Executor 本身并没有要求实现者已何种方式运行这些任务，一个简单的实现类就可以在接受任务时，在主线程中运行它们。如下伪代码：

 

 

public class SimpleExecutor implements Executor {

    public void execute(Runnable runnable) {

        runnable.run(); // 提交任务后直接在主线程中执行

    }

}

 

    但大多数情况下，任务并非在主线程下运行，它们需要在其他线程中运行，下列伪代码稍微有意义些：

 

 

public class SimpleExecutor implements Executor {

   

    public void execute(Runnable runnable) {

        new Thread(runnable).start(); // 提交任务后，在其他线程中执行

    }

}

 

Executor 接口引入了两个子接口：ExecutorService 和 ScheduledExecutorService。

Ø  ExecutorService 接口添加了结束任务的管理方法，此外在提交任务时可获取一个Future实例，以便通过他跟踪异步任务的运行情况。

Ø  ScheduledExecutorService 接口可以对任务进行调度，如指定执行的延迟时间和运行周期。

 

JDK5.0 本身提供的ThreadPoolExecutor 类实现了Executor和ExecutorService这两个接口，它使用一个线程池对任务进行调度。对于处理一些数量巨大的短小并发任务，采用线程池可以带来明显好处（诸如Web服务器、DB服务器、邮件服务器之类的应用需要处理来自远程的大量短小任务）。此外，通过调整线程池中的参数，让人物的数目超过某个阀值时，强制其他任何新的任务阻塞等待，直到获得一个线程来处理为止，从而防止资源无限占用。ThreadPoolExecutor 的子类ScheduledThreadPoolExecutor 实现了ScheduleExecutorService接口。

 

    java.util.concurrent 该包中通过一个综合性工厂类Executors来创建上述这些线程池接口的实例：

Ø  static ExecutorService newFixedThreadPool(int poolSize) ：创建一个可重用固定线程数的线程池，以共享边界队列的方式来运行这些线程。

Ø  static ExecutorService newCachedThreadPool(): 线程池是动态的，不够用时创建新的线程，长时间不用的线程将被收回。

Ø  static ScheduledExecutorService newScheduledThreadPool(int corePoolSize, ThreadFactory tf): 创建一个线程池，它可以安排在给定延迟后运行命令或者定期执行。

 

下面是稍微具体的Demo：

 

 

package com.brofe.concurrent;

 

import java.util.concurrent.Executor;

import java.util.concurrent.Executors;

 

public class ExecutorExample {

 

    private Executor executor = null; // 声明一个执行器，提供Setter方法

   

    private static int poolSize = 3; // 线程池中固定的线程数量

 

    /**

     * 用执行器执行多个任务

     */

    public void executeTasks() {

       for (int i = 0; i < 9; i++) {

           executor.execute(new SimpleTask("任务" + i));

       }

    }

 

    public void setExecutor(Executor executor) {

       this.executor = executor;

    }

   

    public static void main(String[] args) {

       ExecutorExample example = new ExecutorExample();

       example.setExecutor(Executors.newFixedThreadPool(poolSize));

      

       example.executeTasks();

    }

}

 

/**

 * 任务类

 */

class SimpleTask implements Runnable {

 

    private String taskName = null;

   

    public SimpleTask(String taskName) {

       this.taskName = taskName;

    }

   

    public void run() {

       System.out.println("执行名为: " + taskName + " 的线程。 线程编号为: " + Thread.currentThread().getId() );

    }

}

 

执行结果为：

 

执行名为: 任务0 的线程。 线程编号为: 8

执行名为: 任务3 的线程。 线程编号为: 8

执行名为: 任务4 的线程。 线程编号为: 8

执行名为: 任务5 的线程。 线程编号为: 8

执行名为: 任务6 的线程。 线程编号为: 8

执行名为: 任务7 的线程。 线程编号为: 8

执行名为: 任务8 的线程。 线程编号为: 8

执行名为: 任务1 的线程。 线程编号为: 9

执行名为: 任务2 的线程。 线程编号为: 10

 

可见这是10个任务共享了线程池中的三个线程。