import java.io.*;
import java.net.*;

class IoThread extends Thread {
  private Socket skt = null;
  private IoStrategy ioServer;
  private int ioThreadId;
  private static int ioThreadCounter = 1; 
  

  public IoThread(IoStrategy ioServer) {
       this.ioServer = ioServer;
       ioThreadId=ioThreadCounter++;

  }

  public boolean isIdle() {
    return skt == null;
  }

  public synchronized  void setSocket(Socket s) {
    if (skt == null) {
     //** 3 Initialize skt
    skt=s;

    //**  4 Make the thread stop waiting
    notify();
    }
        // else -- log error
  }

  public synchronized void run() {
    while (true) {
      try {
              wait();

            ioServer.ioService(skt);

        skt = null;
      } catch(Exception e) {
        e.printStackTrace();
      }
    }
  } 
}