当前页面: 开发资料首页 → Java 专题 → 一个简单的线程池

一个简单的线程池

摘要: 一个简单的线程池

</td> </tr> <tr> <td height="35" valign="top" class="ArticleTeitle"> 此代码来自《java游戏编程》，北京希望电子出版社。David Brackeen著邱仲潘译。线程池的入门代码。站长整理。
import java.util.LinkedList;

public class ThreadPool extends ThreadGroup {//作为线程组来实现线程池，新颖

<table width="682" height="27" border="0"> <tr> <td width="407"> private boolean isAlive;//此线程池是否激活
private LinkedList taskQueue;//存放任务的链表
private int threadID;//线程池中的线程数
private static int threadPoolID;//用来记数，实例化了多少个线程池对象

/**
创建一个新的线程池.
@param numThreads 池中的线程数.
*/
public ThreadPool(int numThreads) {
super("ThreadPool-" + (threadPoolID++));
setDaemon(true);

isAlive = true;

taskQueue = new LinkedList();
for (int i=0; i new PooledThread().start();//启动numThreads个线程用于执行存于链表中的任务
}
}
</td> <td width="251"> </td> </tr> </table>

public synchronized void runTask(Runnable task) {//往链表中添加任务的方法
if (!isAlive) {
throw new IllegalStateException();
}
if (task != null) {
taskQueue.add(task);//添加任务
notify();//通知等待的线程
}

}

protected synchronized Runnable getTask()//在链表中取任务
throws InterruptedException
{
while (taskQueue.size() == 0) {
if (!isAlive) {
return null;
}
wait();//如果链表中没有任务，等待
}
return (Runnable)taskQueue.removeFirst();//取出任务
}

/**
关闭这个线程池并立即返回。所有线程停止，不执行任何等待的任务。
*/
public synchronized void close() {
if (isAlive) {
isAlive = false;
taskQueue.clear();
interrupt();
}
}

/**
关闭这个线程池，并等待所有运行的线程完成，执行任何等待的任务。
*/
public void join() {
//通知所有等待的线程，这个线程不再活动
synchronized (this) {
isAlive = false;
notifyAll();
}

//等待所有线程完成
Thread[] threads = new Thread[activeCount()];
int count = enumerate(threads);
for (int i=0; i try {
threads[i].join();
}
catch (InterruptedException ex) { }
}
}

/**
PooledThread是在线程池中的一个线程,用于运行任务(Runnables).
*/
private class PooledThread extends Thread {//私有的，内部才能实例化

public PooledThread() {
super(ThreadPool.this,
"PooledThread-" + (threadID++));
}

public void run() {//启动线程时执行的方法
while (!isInterrupted()) {//线程池的关键之处，池中每一个线程只要没有中断，都循环执行任务

// get a task to run
Runnable task = null;
try {
task = getTask();//可能需要等待
}
catch (InterruptedException ex) { }

// if getTask() returned null or was interrupted,
// close this thread by returning.
if (task == null) {
return;
}

// run the task, and eat any exceptions it throws
try {
task.run();
}
catch (Throwable t) {
uncaughtException(this, t);
}//任务处理完毕
}//此线程继续循环，等待或执行任务。
}
}
}

以下是测试程序:
public class ThreadPoolTest {

public static void main(String[] args) {
if (args.length != 2) {
System.out.println("Tests the ThreadPool task.");
System.out.println(
"Usage: java ThreadPoolTest numTasks numThreads");
System.out.println(
" numTasks - integer: number of task to run.");
System.out.println(
" numThreads - integer: number of threads " +
"in the thread pool.");
return;
}
int numTasks = Integer.parseInt(args[0]);//需要运行的任务数
int numThreads = Integer.parseInt(args[1]);//线程池中启动的线程数

// create the thread pool
ThreadPool threadPool = new ThreadPool(numThreads);//生成线程池,启动线程池中的线程

// run example tasks
for (int i=0; i threadPool.runTask(createTask(i));//往线程池中加任务
}

// 关闭池并等待完成所有任务.
threadPool.join();
}

/**
创建简单任务.
*/
private static Runnable createTask(final int taskID) {
return new Runnable() {
public void run() {
System.out.println("Task " + taskID + ": start");

// simulate a long-running task
try {
Thread.sleep(500);
}
catch (InterruptedException ex) { }

System.out.println("Task " + taskID + ": end");
}
};
}

}
运行：

C:\java>java ThreadPoolTest 8 4
Task 0: start
Task 1: start
Task 2: start
Task 3: start
Task 0: end
Task 4: start
Task 2: end
Task 5: start
Task 3: end
Task 6: start
Task 1: end
Task 7: start
Task 4: end
Task 5: end
Task 6: end
Task 7: end

C:\java>

function TempSave(ElementID) { CommentsPersistDiv.setAttribute("CommentContent",document.getElementById(ElementID).value); CommentsPersistDiv.save("CommentXMLStore"); } function Restore(ElementID) { CommentsPersistDiv.load("CommentXMLStore"); document.getElementById(ElementID).value=CommentsPersistDiv.getAttribute("CommentContent"); } </td> </tr> <tr>

↑返回目录
前一篇: 全屏幕工作模式
后一篇: Javamail操作指南