Потоки. Синхронизация и семафоры. Проблема с реализацией

private void ReadSelected_Click(object sender, EventArgs e)
        {
            if (HubsCollection.CheckedItems.Count != 0)
            {              
                thread = new Thread(Do);
                thread.IsBackground = false;
                thread.Start();
            }
            else
            {
                MessageBox.Show("Выберите опрашиваемые концентраторы");
            }
        }
        private void Do()
        {
            string HubFile = @"c:\counters\data\Hubs.cts";
            string con, q, DST_ADDRESS, COUNTER_ADDRESS, COM_PORT_ADDR;
           
            StreamReader StrReader = new StreamReader(HubFile, System.Text.Encoding.Default);
            List<string> HubData = new List<string>();
            while ((con = StrReader.ReadLine()) != null)
            {
                HubData.Add(con);
            }
            for (int y = 0; y < HubData.Count(); y++)
            {                
                q = HubData[y];
                string[] Words = q.Split('!');
                string hex = "0x";
                DST_ADDRESS = Words[2];
                COM_PORT_ADDR = Words[3];
                COUNTER_ADDRESS = Words[5];
                Invoke(new ReceiveHandler(UpdateDisplay), new object[] { "Опрашиваем концентратор: " + DST_ADDRESS + " Счетчик: " + COUNTER_ADDRESS + " Порт: " + COM_PORT_ADDR});
                byte[] bytes = new byte[1024];
               
                string DST_ADD_LF = hex + DST_ADDRESS.Substring(0, 2);
                string DST_ADD_RT = hex + DST_ADDRESS.Substring(2);
                string COUNTER_ADDRESS_LF = hex + COUNTER_ADDRESS.Substring(0, 2);
                string COUNTER_ADDRESS_RT = hex + COUNTER_ADDRESS.Substring(2);
                byte D_A_L = (Convert.ToByte(DST_ADD_LF, 16));
                byte D_A_R = (Convert.ToByte(DST_ADD_RT, 16));
                byte C_A_L = (Convert.ToByte(COUNTER_ADDRESS_LF, 16));
                byte C_A_R = (Convert.ToByte(COUNTER_ADDRESS_RT, 16));
                byte[] data_conf = { 0xff, 0xff, D_A_R, D_A_L, 0x01 };                
                long CRC = CRC24(data_conf);                
                byte[] CRC_24_S = BitConverter.GetBytes(CRC);
               
                //Чтение версии прошивки концентратора
                byte[] GET_VERINFO = { CRC_24_S[0], CRC_24_S[1], CRC_24_S[2], 0xff, 0xff, D_A_R, D_A_L, 0x01, 0x83, 0x82 };
                //чтение текущего времени на коцентраторе
                byte[] GET_TIMEDATE = { CRC_24_S[0], CRC_24_S[1], CRC_24_S[2], 0xff, 0xff, D_A_R, D_A_L, 0x01, 0x81, 0x80 };
                //чтение текущей конфигурации
                byte[] GET_CONFIG = { CRC_24_S[0], CRC_24_S[1], CRC_24_S[2], 0xff, 0xff, D_A_R, D_A_L, 0x01, 0x80, 0x7f };                
                //чтение информации с почтовых ящиков
                byte[] data_rc = { 0xff, 0xff, D_A_R, D_A_L, 0x03 };
                long CRC_1 = CRC24(data_rc);
                byte[] CRC_24_RC = BitConverter.GetBytes(CRC);
                byte[] GET_MAIL = { CRC_24_RC[0], CRC_24_RC[1], CRC_24_RC[2], 0xff, 0xff, D_A_R, D_A_L, 0x03, 0x82, C_A_R, C_A_L, 0x84 };
                System.IO.Ports.SerialPort newPort = new SerialPort(COM_PORT_ADDR, 38400, Parity.None, 8, StopBits.One);
                newPort.ReadTimeout = 1000;
                               
                newPort.RtsEnable = false;
                newPort.DtrEnable = true;
                if (newPort.IsOpen == true)
                {
                    newPort.Close();
                    System.Threading.Thread.Sleep(5 * 1000);
                }
                //Открываем порт и отправляем данные
                newPort.Open();
                newPort.DataReceived += new SerialDataReceivedEventHandler(newPort_DataReceived);
                if (newPort.CtsHolding == true) { } else { };
                Send(newPort, GET_VERINFO, GET_TIMEDATE, GET_CONFIG, GET_MAIL);                
            }
        }
        private void Send(SerialPort newPort, byte[] GET_VERINFO, byte[] GET_TIMEDATE, byte[] GET_CONFIG, byte[] GET_MAIL)
        {
            newPort.Write(GET_VERINFO, 0, GET_VERINFO.Length);
            newPort.Write(GET_TIMEDATE, 0, GET_TIMEDATE.Length);
            newPort.Write(GET_CONFIG, 0, GET_CONFIG.Length);
            newPort.Write(GET_MAIL, 0, GET_MAIL.Length);
        }
        void newPort_DataReceived(object sender, SerialDataReceivedEventArgs e)
        {
            SerialPort port = sender as SerialPort;
            Thread.Sleep(1000);
            int byteRecieved = port.BytesToRead;            
            byte[] messByte = new byte[byteRecieved];
            port.Read(messByte, 0, byteRecieved);            
            port.Close();
            string RecvMsgs = Convert.ToString(messByte.Count());
            Invoke(new ReceiveHandler(UpdateDisplay), new object[] {RecvMsgs});            
        }