Java线程：新特征-线程池-java-IT落伍者

Sun在Java中对Java线程的类库做了大量的扩展其中线程池就是Java的新特征之一除了线程池之外还有很多多线程相关的内容为多线程的编程带来了极大便利为了编写高效稳定可靠的多线程程序线程部分的新增内容显得尤为重要

有关Java线程新特征的内容全部在ncurrent下面里面包含数目众多的接口和类熟悉这部分API特征是一项艰难的学习过程目前有关这方面的资料和书籍都少之又少大所属介绍线程方面书籍还停留在java之前的知识层面上

当然新特征对做多线程程序没有必须的关系在java之前通用可以写出很优秀的多线程程序只是代价不一样而已

线程池的基本思想还是一种对象池的思想开辟一块内存空间里面存放了众多（未死亡）的线程池中线程执行调度由池管理器来处理当有线程任务时从池中取一个执行完成后线程对象归池这样可以避免反复创建线程对象所带来的性能开销节省了系统的资源

在Java之前要实现一个线程池是相当有难度的现在Java为我们做好了一切我们只需要按照提供的API来使用即可享受线程池带来的极大便利

Java的线程池分好多种固定尺寸的线程池可变尺寸连接池

在使用线程池之前必须知道如何去创建一个线程池在Java中需要了解的是ncurrentExecutors类的API这个类提供大量创建连接池的静态方法是必须掌握的

一固定大小的线程池

import ncurrentExecutors;

import ncurrentExecutorService;

/**

* Java线程线程池

* @author Administrator ::

public class Test {

public static void main(String[] args) {

//创建一个可重用固定线程数的线程池

ExecutorService pool = ExecutorsnewFixedThreadPool();

//创建实现了Runnable接口对象Thread对象当然也实现了Runnable接口

Thread t = new MyThread();

//将线程放入池中进行执行

poolexecute(t);

//关闭线程池

poolshutdown();

}

class MyThread extends Thread{

@Override

public void run() {

Systemoutprintln(ThreadcurrentThread()getName()+正在执行);

}

poolthread正在执行

Process finished with exit code

二单任务线程池

在上例的基础上改一行创建pool对象的代码为

//创建一个使用单个 worker 线程的 Executor以无界队列方式来运行该线程

ExecutorService pool = ExecutorsnewSingleThreadExecutor();

输出结果为

poolthread正在执行

Process finished with exit code

对于以上两种连接池大小都是固定的当要加入的池的线程（或者任务）超过池最大尺寸时候则入此线程池需要排队等待

一旦池中有线程完毕则排队等待的某个线程会入池执行

三可变尺寸的线程池

与上面的类似只是改动下pool的创建方式

//创建一个可根据需要创建新线程的线程池但是在以前构造的线程可用时将重用它们

ExecutorService pool = ExecutorsnewCachedThreadPool();

poolthread正在执行

Process finished with exit code

四延迟连接池

import ncurrentExecutors;

import ncurrentScheduledExecutorService;

import ncurrentTimeUnit;

/**

* Java线程线程池

* @author Administrator ::

public class Test {

public static void main(String[] args) {

//创建一个线程池它可安排在给定延迟后运行命令或者定期地执行

ScheduledExecutorService pool = ExecutorsnewScheduledThreadPool();

//创建实现了Runnable接口对象Thread对象当然也实现了Runnable接口

Thread t = new MyThread();

//将线程放入池中进行执行

poolexecute(t);

//使用延迟执行风格的方法

poolschedule(t TimeUnitMILLISECONDS);

//关闭线程池

poolshutdown();

}

class MyThread extends Thread {

@Override

public void run() {

Systemoutprintln(ThreadcurrentThread()getName() + 正在执行);

}

poolthread正在执行

Process finished with exit code

五单任务延迟连接池

在四代码基础上做改动

//创建一个单线程执行程序它可安排在给定延迟后运行命令或者定期地执行

ScheduledExecutorService pool = ExecutorsnewSingleThreadScheduledExecutor();

poolthread正在执行

Process finished with exit code

六自定义线程池

import ncurrentArrayBlockingQueue;

import ncurrentBlockingQueue;

import ncurrentThreadPoolExecutor;

import ncurrentTimeUnit;

/**

* Java线程线程池自定义线程池

* @author Administrator ::

public class Test {

public static void main(String[] args) {

//创建等待队列

BlockingQueue<Runnable> bqueue = new ArrayBlockingQueue<Runnable>();

//创建一个单线程执行程序它可安排在给定延迟后运行命令或者定期地执行

ThreadPoolExecutor pool = new ThreadPoolExecutor(TimeUnitMILLISECONDSbqueue);

//创建实现了Runnable接口对象Thread对象当然也实现了Runnable接口

Thread t = new MyThread();

//将线程放入池中进行执行

poolexecute(t);

//关闭线程池

poolshutdown();

}

class MyThread extends Thread {

@Override

public void run() {

Systemoutprintln(ThreadcurrentThread()getName() + 正在执行);

try {

Threadsleep(L);

} catch (InterruptedException e) {

eprintStackTrace();

}

poolthread正在执行

Process finished with exit code

创建自定义线程池的构造方法很多本例中参数的含义如下

ThreadPoolExecutor

public ThreadPoolExecutor(intcorePoolSize intmaximumPoolSize longkeepAliveTime TimeUnitunit BlockingQueue<Runnable>workQueue)

用给定的初始参数和默认的线程工厂及处理程序创建新的 ThreadPoolExecutor使用 Executors 工厂方法之一比使用此通用构造方法方便得多

参数: corePoolSize 池中所保存的线程数包括空闲线程; maximumPoolSize 池中允许的最大线程数; keepAliveTime 当线程数大于核心时此为终止前多余的空闲线程等待新任务的最长时间; unit keepAliveTime 参数的时间单位; workQueue 执行前用于保持任务的队列此队列仅保持由 execute 方法提交的 Runnable 任务
抛出: IllegalArgumentException 如果 corePoolSize 或 keepAliveTime 小于零或者 maximumPoolSize 小于或等于零或者 corePoolSize 大于 maximumPoolSize; NullPointerException 如果 workQueue 为 null

自定义连接池稍微麻烦些不过通过创建的ThreadPoolExecutor线程池对象可以获取到当前线程池的尺寸正在执行任务的线程数工作队列等等

有关Java线程池的内容到此就没有了更多的内容还需要研读API来获取