commbuffer.java.svn-base

通讯采集软件

package pbs.application.iiop.GUI;

import java.util.*;
import pbs.application.iiop.GUI.huadong.*;

public class CommBuffer
{
      private static String[] YCBuffer = new String[256];
      private static String[] HDBuffer = new String[256];
      private static String[] DMISBuffer = new String[256];
      
      private static int YCwritemark = 0;
      private static int YCreadmark = 0;
     
      
      private static int HDwritemark = 0;
      private static int HDreadmark = 0;
      
      private static int DMISwritemark = 0;
      private static int DMISreadmark = 0;
      
      public static final int YCTYPE = 0;
      public static final int HDTYPE = 1;
      public static final int DMISTYPE = 2;
      
      public static boolean YCExit = true;
      public static boolean HDExit = true;
      public static boolean DMISExit = true;
      
      public static ArrayList m_DateList = null;
      public static boolean IsRunning = false;
      
      public static CommGui m_CommGui = null;
      public static huaDong m_huaDong = null;
      public static int PURSUE = 1;
      public static int ONTIME = 2;
      
      
      public CommBuffer()
      {
      }
      
      public static void putResult(int type,String m_String)
      {
            String[] m_Buffer = null;
            int writemark = 0;
            int readmark = 0;
            //System.out.println("进入了CommBuffer.putResult()");
            switch(type)
            {
                  case YCTYPE:
                        m_Buffer = YCBuffer;
                        writemark = YCwritemark;
                        readmark = YCreadmark;
                        break;
                  case HDTYPE:
                        m_Buffer = HDBuffer;
                        writemark = HDwritemark;
                        readmark = HDreadmark;
                        break;
                case DMISTYPE:
                        m_Buffer = DMISBuffer;
                        writemark = DMISwritemark;
                        readmark = DMISreadmark;
                        break;
                  default:
                        return;
            }
            synchronized(m_Buffer)
            {
                  //System.out.println("CommBuffer写入了:"+m_String);
                  if(writemark < 255)
                  {
                        m_Buffer[writemark+1] = m_String;
                        writemark += 1;
                        //System.out.println("the writemark is :"+writemark);
                  }
                  else
                  {
                        if(writemark == 255)
                        {
                              m_Buffer[0] = m_String;
                              writemark = 0;
                              //System.out.println("the writemark is :"+writemark);
                        }
                  }
                  switch(type)
                  {
                        case YCTYPE:
                              YCBuffer=m_Buffer;
                              YCwritemark = writemark;
                              YCreadmark = readmark;
                              break;
                        case HDTYPE:
                              HDBuffer = m_Buffer;
                              HDwritemark = writemark;
                              HDreadmark = readmark;
                              break;
                        case DMISTYPE:
                              DMISBuffer = m_Buffer;
                              DMISwritemark = writemark;
                              DMISreadmark = readmark;
                              break;
                        default:
                              return;
                  }
            }
      }
      
      public static ArrayList getResult(int type)
      {
            String[] m_Buffer = null;
            int writemark = 0;
            int readmark = 0;
            //System.out.println("进入了CommBuffer.getResult()");
            switch(type)
            {
                  case YCTYPE:
                        m_Buffer = YCBuffer;
                        writemark = YCwritemark;
                        readmark = YCreadmark;
                        break;
                  case HDTYPE:
                        m_Buffer = HDBuffer;
                        writemark = HDwritemark;
                        readmark = HDreadmark;
                        break;
                  case DMISTYPE:
                        m_Buffer = DMISBuffer;
                        writemark = DMISwritemark;
                        readmark = DMISreadmark;
                        break;
                  default:
                        return null;
            }
            synchronized(m_Buffer)
            {
                  ArrayList MyResult = new ArrayList();
                  if(readmark == writemark)
                        return null;
                  else
                  {
                        if(readmark < writemark)
                        {
                              for(int i=readmark; i<writemark; i++)
                              {
                                    MyResult.add(m_Buffer[i+1]);
                                    //System.out.println("读出。。。"+m_Buffer[i+1]);
                              }
                              readmark = writemark;
                        }
                        else
                        {
                              for(int i=readmark; i<255; i++)
                              {
                                    MyResult.add(m_Buffer[i+1]);
                                    //System.out.println("读出。。。"+m_Buffer[i+1]);
                              }
                              for(int i=0; i<writemark; i++)
                              {
                                    MyResult.add(m_Buffer[i]);
                                    //System.out.println("读出。。。"+m_Buffer[i]);
                              }
                              readmark = writemark;
                        }
                        switch(type)
                        {
                              case YCTYPE:
                                    YCreadmark = readmark;
                                    break;
                              case HDTYPE:
                                    HDreadmark = readmark;
                                    break;
                              case DMISTYPE:
                                    DMISreadmark = readmark;
                                    break;
                              default:
                                    break;
                        }
                        return MyResult;
                  }
            }
      }
}