J2SE5.0中的线程缓冲 ---- 线程池

J2SE5.0中的线程缓冲 ---- 线程池2011-05-20一、前言

用Java编写多线程程序已经是一个非常简单的事了，不过与其它多线程系统相比，一些高级特性在Java中仍然不具备，然而在J2SE5.0中这一切将会改变。J2SE5.0增加大量的线程相关类使得编写多线程程序更加容易！

二、线程池－Thread Pools

线程库的基本思想简单的讲就是，一个线程库中拥有一定数量的线程，当有任务要执行时，就从线程库中找一个空闲的线程来执行这个任务，任务执行完后，该线程返回线程库等待下一个任务;如果线程库中没有空闲的线程来执行该任务，这时该任务将要等待直到有一个空闲的线程来执行它。这听起来有点不爽，那么我们为什么还要使用线程库呢？

三、使用线程库的三大理由

重用线程能够获得性能上的好处。在多线程环境中，创建一个线程要花很高的代价。线程库使得线程能够被重用，当有大量任务要执行时，线程库避免了不断创建与销毁线程所带来的系统开销，使用得你的程序整体运行效率得到了一定程度的提高。

还有一个很重要的原因就是，线程库考虑到了较好的程序设计。如果有大量任务要执行，如果不用线程库，你不得不不重复创建一个线程、管理这个线程的生命同期的代码。断重复这些步骤是一件很乏味的工作，因为这与我们的业务逻辑（任务）无关。使用线程库，这一切将由线程库代为管理，你只需关注于你的商务逻辑，当要执行一个任务时，你只需简单的创建一个任务，并把它丢给线程库去执行就OK。

最后一个也是最为重要的一个：当有大量任务需要同时执行时，线程库能够带来重大的性能提升。这一点看上去与第一点相似，事实上，任何时候活动的线程都比CPU数量多得多，因此线程库能够充分利用CPU的时间片，使得程序看去上运行较快且高效。

四、如何使用线程库

在使用线程库需要做两件事：创建任务及建立线程库本身。

一个任务是一个实现了Runnable或Callable接口的对象。

线程库则基于Executor接口。

java.util.concurrent.Executor
△
┆
java.util.concurrent.ExecutorService
△
│
java.util.concurrent.ThreadPoolExecutor

package java.util.concurrent;
public class ThreadPoolExecutor implements ExecutorService ...{
   public ThreadPoolExecutor（int corePoolSize,
                int maximumPoolSize,
                long keepAliveTime,
                TimeUnit unit,
                BlockingQueue<Runnable> workQueue）;
   public ThreadPoolExecutor（int corePoolSize,
                int maximumPoolSize,
                long keepAliveTime,
                TimeUnit unit,
                BlockingQueue<Runnable> workQueue,
                ThreadFactory threadFactory）;
   public ThreadPoolExecutor（int corePoolSize,
                int maximumPoolSize,
                long keepAliveTime,
                TimeUnit unit,
                BlockingQueue<Runnable> workQueue,
                RejectedExecutionHandler handler）;
   public ThreadPoolExecutor（int corePoolSize,
                int maximumPoolSize,
                long keepAliveTime,
                TimeUnit unit,
                BlockingQueue<Runnable> workQueue,
                ThreadFactory threadFactory,
                RejectedExecutionHandler handler）;
}