工作沒(méi)來(lái)就一直等，工作來(lái)了就干活。

示例程序

• Main 測(cè)試程序行為的類
• ClientThread 表示發(fā)出工作請(qǐng)求的線程的類
• Request 表示工作請(qǐng)求的類
• Channel 收到工作請(qǐng)求并將工作請(qǐng)求交給工人線程的類
• WorkerThread 表示工人線程的類

Main 類

public class Main {
  public static void main (String[] args) {
    Channel channel = new Channel(5);   //工人線程的個(gè)數(shù)
    channel.startWorkers();
    new ClientThread("Alice", channel).start();
    new ClientThread("Bobby", channel).start();
    new ClientThread("Chris", channel).start();
  }
}

ClientThread 類

import java.util.Random;

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 (InterruptException e) {}
  }
}

Request 類

import java.util.Random;

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 + " ]";
  }
} 

Channel 類

public class Channel {
  private static final int MAX_REQUEST = 100;
  private final Request[]  requestQueue;
  private int tail ;    //下次putRequest的位置
  private int head;  //下次takeRequest的位置
  private int count ;  // Request 的數(shù)量 
  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;
    }
  }
}

Worker Thread 類

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();
    }
  }
}

Worker Thread 模式中的登場(chǎng)角色

• Client (委托者)
  Client 角色創(chuàng)建表示工作請(qǐng)求的Request角色，并將其傳遞給Channel角色。在示例程序中，由ClientThread類扮演此角色。
• Channel （通訊線路）
  Channel角色接受來(lái)自Client角色的Rquest角色，并將其傳遞給Worker角色。在示例程序中，由Channel類扮演此角色。
• Worker （工人）
  Worker角色從Channel角色中獲取Request角色，并進(jìn)行工作。當(dāng)一項(xiàng)工作完成后，它會(huì)繼續(xù)去獲取另外的Request角色。在示例程序中，由WorkerThread類扮演此角色。
• Request（請(qǐng)求）
  Request角色是表示工作的角色。Request角色中保存了進(jìn)行工作所必需的信息。在示例程序中，由Request類扮演此角色。