threadmanager.java

短信网关发送接受平台。

import Utilities.*;
import java.io.*;
import Services.*;
/**
 * <p>Title: InHand SMS platform XMLRouter</p>
 * <p>Description: InHand 短信服务平台服务路由器</p>
 * <p>Copyright: Copyright (c) 2002</p>
 * <p>Company: 北京映翰通网络技术有限公司</p>
 * @author 韩传俊 [e-mail]
 * @version 1.0
 */

public class ThreadManager extends Engine {
        public  boolean is_Running=true;
        public XMLRouter router=null;
        public String today;
        public ThreadManager(XMLRouter router) {
                super("ThreadManager");
                this.router=router;
                today=Utility.getDateString();
        }

        public void run(){
                DataInputStream in=new DataInputStream(System.in);
                String inStr="";
                ServiceInfo serviceInfo=null;
                while (is_Running){
                        if (!today.equalsIgnoreCase(Utility.getDateString())){
                                today=Utility.getDateString();
                                Config.resetCounter();
                                for (int i=0;i<Config.subcode_item.size();i++){
                                        serviceInfo=(ServiceInfo)Config.subcode_item.elementAt(i);
                                        serviceInfo.reset();
                                }
                                for (int i=0;i<Config.service_id_item.size();i++){
                                        serviceInfo=(ServiceInfo)Config.service_id_item.elementAt(i);
                                        serviceInfo.reset();
                                }
                        }
                        System.out.println("================================================================");
                       System.out.println("MT Total："+Config.getMt());
                       System.out.println("MO Total："+Config.getMo());

                        System.out.println("XMLCenter input :"+Config.getIn()+"\t Recv Queue: "+Config.recv_queue.getSize()+"\r\n\t\t service queue:"+Config.service_id_queue.getSize()+"\t subcode queue:"+Config.subcode_queue.getSize());
                        System.out.println("XMLCenter output:"+Config.getOut()+"\t Send Queue: "+Config.send_queue.getSize());
                        for (int i=0;i<Config.subcode_item.size();i++){
                                serviceInfo=(ServiceInfo)Config.subcode_item.elementAt(i);
                                System.out.println(" module["+serviceInfo.id+"]:\r\n   connect: "+serviceInfo.is_connect+"\t Send Queue:"+serviceInfo.data.getSize()+"\t input:"+serviceInfo.getInputNumber()+"\t output:"+serviceInfo.getOutputNumber()+"\r\n\t\t MT:"+serviceInfo.getMt()+"\t MO:"+serviceInfo.getMo());

                        }
                        for (int i=0;i<Config.service_id_item.size();i++){
                                serviceInfo=(ServiceInfo)Config.service_id_item.elementAt(i);
                                System.out.println(" module["+serviceInfo.id+"]:\r\n   connect: "+serviceInfo.is_connect+"\t Send Queue:"+serviceInfo.data.getSize()+"\t input:"+serviceInfo.getInputNumber()+"\t output:"+serviceInfo.getOutputNumber()+"\r\n\t\t MT:"+serviceInfo.getMt()+"\t MO:"+serviceInfo.getMo());
                        }

                        try{
                                //inStr=in.readLine();
                                Thread.sleep(5000);
                        }catch(Exception e){
                                e.printStackTrace();
                                Config.log.log(e,"in ThreadManager read input!");
                        }
                  /*      if(inStr!=null && inStr.equalsIgnoreCase("quit")){
                                this.is_Running=false;
                                this.router.isRunning=false;
                                System.out.println("recieve the command: quit,System quit ...");
                                Config.log.log("recieved the \"quit\" command ,System quit ...");
                        }
                */
                }
        }

        public static void main(String[] args) {
               // ThreadManager threadManager1 = new ThreadManager();
        }
}