poolablethread.java

21天学通java的示例程序源代码

//PoolableThread.java

package com.wrox.threadpool;

class PoolableThread extends Thread {

  Runnable task = null;
  ThreadPool pool;

  PoolableThread(ThreadPool pool) {
    this.pool = pool;
  }

  synchronized void setTask(Runnable task) {
    this.task = task;
    notify();
  } 

  synchronized void executeTasks() {
    for (; ; ) {
      try {
        if (task == null) {
          wait();
        } 
      } catch (InterruptedException ex) {

        // Interrupted
      } 
      task.run();
      task = null;
      pool.free(this);
    } 
  } 
  public void run() {
    executeTasks();
  } 
}