现在的位置: 首页 > 综合 > 正文

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

2014年01月14日 ⁄ 综合 ⁄ 共 1903字 ⁄ 字号 评论关闭

一、前言

用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);
}

抱歉!评论已关闭.