COM-порт, работа с двумя формами и одним буфером обмена - C# - Ответ 2837265

//
// Form1.cs основной класс
//
 
// ...
 
private DbgExch DebugCOM = new DbgExch(); // экземпляр класса, работающего с ком-портом
 
// ...
 
    private void timerConn_Tick(object sender, EventArgs e) // чтение по таймеру
        {
            timerConn.Stop();
            if (DebugCOM != null)
            {
                string s = DebugCOM.GetResponse(); // здесь происходит чтение буфера и его обнуление
                if (s.Length > 0)
                {
                    richTextBox1.Text += s;
                    responseString = s;
                    CursorStart = richTextBox1.SelectionStart = richTextBox1.Text.Length;
                }
                timerConn.Start();
            }
        }
// ...

//
// DbgExch.cs - класс работающий с ком-портом
//
 
    public DbgExch() // конструктор класса
    {
            response = new ArrayList();
            com = new SerialPort("COM4", 115200);
            com.ReadTimeout = 3000;
            com.WriteTimeout = 1000;
            com.DataBits = 8;           // 8 - default
            com.StopBits = StopBits.One;// One - default
            try
            {
                com.Open();
            }
            catch(Exception err)
            {
                MessageBox.Show("Error: " + err.Message);
                com_status = "Error opening COM4: " + err.Message;
            }
 
        responseSignal = new Object();
        reportSignal = new Object();
        receiveThread = new Thread(new ThreadStart(Receive));
        receiveThread.Start();
    }
 
// ...
 
    private void Receive() // получение данных с порта
    {
            byte[] receiveBuffer = new byte[MAX_PACKET_LENGTH];
            bool eol = false;
            int bytesRead = 0;
 
            while (true)
            {
        try
        {
                    bytesRead = 0;
                    eol = false;
 
                    while ((!eol) && (bytesRead < (MAX_PACKET_LENGTH-1)))
            {
                        try
                        {
                            bytesRead += com.Read(receiveBuffer, bytesRead, 1);
                            if (bytesRead < 1) continue;
                            if (bytesRead > (MAX_PACKET_LENGTH-1)) 
                            {
                                bytesRead = 0;
                                continue;
                            }
                            // Ждем первый символ          //ждем приема ДО таймаута или до eol
                            eol = bytesRead > 0;
                            continue;
                        }
                        catch (TimeoutException)
                        {
                            _timedOut = true;
                            bytesRead = 0;
                            continue;
                        }
            }
                    Encoding ascii = Encoding.ASCII;
                    string msg2 = Encoding.GetEncoding(1251).GetString(receiveBuffer, 0, bytesRead);
                    AddResponse(msg2);
 
                }
 
        catch (IOException)
        {
            // abort the thread
            System.Threading.Thread.CurrentThread.Abort();
        }
        catch (ObjectDisposedException)
        {
            if (receiveThread != null)
            {
                receiveThread = null;
            }
        }
            }
    }
 
// ...        
 
        private void AddResponse(string msg) // Заполнение буфера приёма
    {
        lock (responseSignal)
        {
                    ArrayList r = (ArrayList) response;
            r.Add( msg);
            Monitor.Pulse(responseSignal);
        }
    }
 
// ...
 
        public string GetResponse() // Чтение буфера и его обнуление
        {
            string rss = "";
            lock (responseSignal)
            {
                ArrayList r = (ArrayList)response;
                while ((r.Count > 0)/* && (N-- > 0)*/)
                {
                    rss += (String) r[0];
                    r.RemoveAt(0);
                }
            }
            return rss;
        }