摘要：通道參與者參與者保存請(qǐng)求隊(duì)列，同時(shí)會(huì)預(yù)創(chuàng)建線程。注啟動(dòng)線程是一項(xiàng)繁重的工作，模式預(yù)先創(chuàng)建一批線程，可以重復(fù)使用線程，達(dá)到資源再利用提升性能的目的。

Work Thread模式和Thread-Per-Message模式類似，Thread-Per-Message每次都創(chuàng)建一個(gè)新的線程處理請(qǐng)求，而Work Thread模式預(yù)先會(huì)創(chuàng)建一個(gè)線程池（Thread Pool），每次從線程池中取出線程處理請(qǐng)求。

Request請(qǐng)求類：

public class Request {
    private final String name;
    private final int number;
    private static final Random random = new Random();
    public Request(String name, int number) {
        this.name = name;
        this.number = number;
    }
    public void execute() {
        System.out.println(Thread.currentThread().getName() + " executes " + this);
        try {
            Thread.sleep(random.nextInt(1000));
        } catch (InterruptedException e) {
        }
    }
    public String toString() {
        return "[ Request from " + name + " No." + number + " ]";
    }
}

Client線程類：
Client線程類用來(lái)送出請(qǐng)求：

創(chuàng)建Request實(shí)例

將這個(gè)實(shí)例傳送給Channel類的putRequest方法

public class ClientThread extends Thread {
    private final Channel channel;
    private static final Random random = new Random();
    public ClientThread(String name, Channel channel) {
        super(name);
        this.channel = channel;
    }
    public void run() {
        try {
            for (int i = 0; true; i++) {
                Request request = new Request(getName(), i);
                channel.putRequest(request);
                Thread.sleep(random.nextInt(1000));
            }
        } catch (InterruptedException e) {
        }
    }
}

Worker線程類：
WorkerThread類表示工人線程，工人線程可以執(zhí)行以下動(dòng)作：

從Channel實(shí)例取出Request實(shí)例

調(diào)用Request實(shí)例的execute方法

public class WorkerThread extends Thread {
    private final Channel channel;
    public WorkerThread(String name, Channel channel) {
        super(name);
        this.channel = channel;
    }
    public void run() {
        while (true) {
            Request request = channel.takeRequest();
            request.execute();
        }
    }
}

Channel類：

/**
 *Channel類可用來(lái)接受、傳送工作請(qǐng)求，并保存工人線程。
 */
public class Channel {
    private static final int MAX_REQUEST = 100; // 最大請(qǐng)求數(shù)
    private final Request[] requestQueue;         // 請(qǐng)求隊(duì)列
    private int tail;
    private int head;
    private int count;
    private final WorkerThread[] threadPool;
?
    public Channel(int threads) {
        this.requestQueue = new Request[MAX_REQUEST];
        this.head = 0;
        this.tail = 0;
        this.count = 0;
?
        threadPool = new WorkerThread[threads];
        for (int i = 0; i < threadPool.length; i++) {
            threadPool[i] = new WorkerThread("Worker-" + i, this);
        }
    }
    public void startWorkers() {
        for (int i = 0; i < threadPool.length; i++) {
            threadPool[i].start();
        }
    }
    public synchronized void putRequest(Request request) {
        while (count >= requestQueue.length) {
            try {
                wait();
            } catch (InterruptedException e) {
            }
        }
        requestQueue[tail] = request;
        tail = (tail + 1) % requestQueue.length;
        count++;
        notifyAll();
    }
    public synchronized Request takeRequest() {
        while (count <= 0) {
            try {
                wait();
            } catch (InterruptedException e) {
            }
        }
        Request request = requestQueue[head];
        head = (head + 1) % requestQueue.length;
        count--;
        notifyAll();
        return request;
    }
}

執(zhí)行：

public class Main {
    public static void main(String[] args) {
        Channel channel = new Channel(5);
        channel.startWorkers();
        new ClientThread("Alice", channel).start();
        new ClientThread("Bobby", channel).start();
        new ClientThread("Chris", channel).start();
    }
}

Work Thread模式的角色如下：

Client（委托人）參與者

Client參與者會(huì)創(chuàng)建請(qǐng)求(Request)，然后傳送給Channel參與者。

Channel（通道）參與者

Channel參與者保存Request請(qǐng)求隊(duì)列，同時(shí)會(huì)預(yù)創(chuàng)建Worker線程。

Worker（工人）參與者

Worker參與者會(huì)從Channel獲取Request。

Request（請(qǐng)求）參與者

Worker參與者會(huì)從Channel獲取Request。

注：?jiǎn)?dòng)線程是一項(xiàng)繁重的工作，Worker Thread模式預(yù)先創(chuàng)建一批線程，可以重復(fù)使用線程，達(dá)到資源再利用、提升性能的目的。