Open Flash Server(OFS) Code

/**
 * <strong>socket连接获取, 消息处理线程</strong>
 * <p>
 *
 * </p>
 *
 * @author: 汉娱网络.技术部.yangxf
 * @date: 2007-12-26
 * @version: 1.1
 **/
package com.handjoys;

import com.handjoys.logger.FileLogger;

public class EventReader extends Thread {
    private GameServer gs;
    private Thread thread;

    public EventReader(GameServer gs) {
    	this.gs = gs;
        thread = new Thread(this, "eventreader");
        FileLogger.info("EventReader threads init, Create thread: " + thread);

        thread.start();
    }

    public void run() {
        while(!gs.IS_SHUTTING_DOWN) {
            gs.readIncomingMessages();
            try {
                Thread.sleep(2L);
            }catch(InterruptedException interruptedexception) {

            }
        }
    }
}