poolablethread.java

java网络编程

package multithread;



/**
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2004</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */

public class PoolableThread extends Thread{

  Runnable task=null;
  ThreadPool pool;

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

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

  }

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

      }
      task.run();
      task=null;
      pool.free(this);

    }
  }

  public void run(){
    excuteTasks();
  }
}