package train.server;

import java.net.*;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: 沈陽化工學院計算機</p>
 *
 * @author 彭勝勇 胡林
 * @version 1.0
 */
public class IOThread extends Thread {
    IoStrategy brokerServer;
    Socket skt;
    int num;
    public static int count;
    public IOThread(IoStrategy brokerServer) {
        this.brokerServer = brokerServer;
        num = count++;
    }
    public void run() {
        while (true) {
            System.out.println("Thread " + num + " is in waiting stage.");
            synchronized (this) {
                try {
                    this.wait();
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
            System.out.println("Thread " + num + " is in service stage.");
            this.brokerServer.ioService(skt);
            this.skt = null;
        }

    }

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

    public synchronized void setSocket(Socket skt) {
        if (this.skt == null) {
            this.skt = skt;
            this.notify();
        }
    }

    public String toString() {
        return "Thread " + num + ":" + skt;
    }
}