Design Pattern: Worker Thread 方式

Design Pattern: Worker Thread 模式

Worker Thread模式在Request的管理上像是 Producer Consumer 模式，在Request的行为上像是 Command 模式。

Producer Consumer模式专注于Product的生产与消费，至于Product被消费时是作何处理，则不在它的讨论范围之中。 如果您的Product是一个Request，消费者取得Request之后，执行Request中指定的请求方法，也就是使用Command模式，并且您的Request缓冲区还管理了Consumer，就有Worker Thread模式的意思了。在Sequence Diagram上，可以看出Worker Thread同时展现了Producer Consumer模式与Command模式：

利用Java实现的一个Channel类如下所示：

import java.util.LinkedList; public class Channel {     private LinkedList requests;     private WorkerThread[] workerThreads;     public Channel(int threadNumber) {         requests = new LinkedList();         workerThreads = new WorkerThread[threadNumber];         for(int i = 0; i < workerThreads.size(); i++) {             workerThreads[i] = new WorkerThread();            workerThreads[i].start();         }     }     public synchronized void putRequest(Request request) {         while(requests.size() >= 2) { // 容量限制为 2             try {                 wait();             }             catch(InterruptedException e) {}         }         requests.addLast(request);         notifyAll();     }         public synchronized Request getProduct() {         while(requests.size() <= 0) {             try {                 wait();             }             catch(InterruptedException e) {}         }         Request request = (Request) requests.removeFirst();         notifyAll();               return request;    } } 

Request类与WorkerThread类之间采的Command模式：

public class Request() {     // ....     public void execute() {         // do some work....     } } 

?

public class WorkerThread extends Thread {     // ...     public void run() {         while(true) {             Request request = channel.getRequest();             request.execute();         }     } } 

就行为上，WorkerThread就是有请求来了就作，如果没有请求，则所有的WorkerThread就等待，直到有新的工作进来而通知它们，取得请求的WorkerThread要作的工作，就直接定义在execute()中。