threadmanager.java~36~

短信网关发送接受平台。

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.mt_recorder_number=0;
                                Config.mo_recorder_number=0;
                                Config.input_recorder_number=0;
                                Config.output_recorder_number=0;
                                for (int i=0;i<Config.subcode_item.size();i++){
                                        serviceInfo=(ServiceInfo)Config.subcode_item.elementAt(i);

                                }
                                for (int i=0;i<Config.service_id_item.size();i++){
                                        serviceInfo=(ServiceInfo)Config.service_id_item.elementAt(i);

                                }
                        }
                        System.out.println("================================================================");
                       System.out.println("MT Total："+Config.mt_recorder_number);
                       System.out.println("MO Total："+Config.mo_recorder_number);

                        System.out.println("XMLCenter input :"+Config.input_recorder_number+"\t\tRecv Queue: "+Config.recv_queue.getSize());
                        System.out.println("XMLCenter output:"+Config.output_recorder_number+"\t\tSend 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.input_number+"\t output:"+serviceInfo.output_number+"\t MT:"+serviceInfo.mt+"\t MO:"+serviceInfo.mo);

                        }
                        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.input_number+"\t output:"+serviceInfo.output_number+"\t MT:"+serviceInfo.mt+"\t MO:"+serviceInfo.mo);
                        }

                        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();
        }
}