java多线程设计模式详解之三

　　前面谈了多线程应用程序能极大地改善用户相应。例如对于一个Web应用程序，每当一个用户请求服务器连接时，服务器就可以启动一个新线程为用户服务。

　　然而，创建和销毁线程本身就有一定的开销，假如频繁创建和销毁线程，CPU和内存开销就不可忽略，垃圾收集器还必须负担更多的工作。因此，线程池就是为了避免频繁创建和销毁线程。

　　每当服务器接受了一个新的请求后，服务器就从线程池中挑选一个等待的线程并执行请求处理。处理完毕后，线程并不结束，而是转为阻塞状态再次被放入线程池中。这样就避免了频繁创建和销毁线程。

　　Worker Pattern实现了类似线程池的功能。首先定义Task接口：

　　package com.crackj2ee.thread;
　　public interface Task {
　　    void execute();
　　}

　　线程将负责执行execute()方法。注重到任务是由子类通过实现execute()方法实现的，线程本身并不知道自己执行的任务。它只负责运行一个耗时的execute()方法。

　　具体任务由子类实现，我们定义了一个CalculateTask和一个TimerTask：

　　// CalculateTask.Java
　　package com.crackj2ee.thread;
　　public class CalculateTask implements Task {
　　    private static int count = 0;
　　    private int num = count;
　　    public CalculateTask() {
　　        count++;
　　    }
　　    public void execute() {
　　        System.out.println("[CalculateTask " + num + "] start...");
　　        try {
　　            Thread.sleep(3000);
　　        }
　　        catch(InterruptedException ie) {}
　　        System.out.println("[CalculateTask " + num + "] done.");
　　    }
　　}

　　// TimerTask.java
　　package com.crackj2ee.thread;
　　public class TimerTask implements Task {
　　    private static int count = 0;
　　    private int num = count;
　　    public TimerTask() {
　　        count++;
　　    }
　　    public void execute() {
　　        System.out.println("[TimerTask " + num + "] start...");
　　        try {
　　            Thread.sleep(2000);
　　        }
　　        catch(InterruptedException ie) {}
　　        System.out.println("[TimerTask " + num + "] done.");
　　    }
　　}

　　以上任务均简单的sleep若干秒。

　　TaskQueue实现了一个队列，客户端可以将请求放入队列，服务器线程可以从队列中取出任务：

　　package com.crackj2ee.thread;
　　import java.util.*;
　　public class TaskQueue {
　　    private List queue = new LinkedList();
　　    public synchronized Task getTask() {
　　        while(queue.size()==0) {
　　            try {
　　                this.wait();
　　            }
　　            catch(InterruptedException ie) {
　　                return null;
　　            }
　　        }
　　        return (Task)queue.remove(0);
　　    }
　　    public synchronized void putTask(Task task) {
　　        queue.add(task);
　　        this.notifyAll();
　　    }
　　}