inputthread.java

GPRS数据通讯软件源码

/*
 * To change this template, choose Tools | Templates
 * and open the template in the editor.
 */

package documenteditor;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 *
 * @author wangzhi1
 * 
 */
public class InputThread extends Thread{
    
    private boolean runing = true;
    
    private InputStream socketIn = null;
    
    private MessageQueue InputQueue = null;
    
    private BufferedReader br = null;
    
    private LogClass logClass = null;//写日志线程
    
    public InputThread(InputStream socketIn,MessageQueue InputQueue,LogClass logClass){
        this.socketIn = socketIn;
        this.InputQueue = InputQueue;
        this.logClass = logClass;
        br = new BufferedReader(new InputStreamReader(socketIn));
    }
    
    @Override
    public void run(){
        while(isRuning()){
            try {
                sleep(1000);
                char[] target = new char[1024];
                br.read(target);
                String temp = (new String(target)).trim();
                logClass.SendWriteLog(temp, "ShengInput");
                InputQueue.Enqueue(temp);
            } catch (IOException ex) {
                //Logger.getLogger(InputThread.class.getName()).log(Level.SEVERE, null, ex);                
                runing = false;
            } catch (InterruptedException ex) {
                Logger.getLogger(InputThread.class.getName()).log(Level.SEVERE, null, ex);
            }
        }
    }

    public boolean isRuning() {
        return runing;
    }

}