Доброе время суток. Извиняюсь что так написал название темы, но суть оно отражает. А проблема в следующем:
Я пишу код, который в одном потоке считывает данные из файла и передает их в последовательный порт компьютера. Второй поток возникает по событию DataReceived.
Так вот проблема возникла в связи с тем, что мне необходимо закрывать порт по окончании приема данных, и открывать его снова, при отправке. Но вероятно по причине параллельности выполнения потоков, порт не успевает закрываться. Но если проверяю проверяю с точками останова, ошибки не возникает.
Подскажите пожалуйста каким образом можно избежать данной ошибки.
Насколько я понимаю, необходимо сделать так, что бы первый поток не выполнялся пока не завершится поток по событию DataReceived, но как это сделать, я не знаю.
Проблемный код предоставляю ниже:
| Код |
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});
}
|
PS: Причина, по которой порт необходимо закрывать по окончании приема данных, заключается в том, что в файле, который я читаю в начале порты могут быть разные (образец строки из файла 1!2380!23d8!COM3!1!0003!), а считывать и получать данные от устройств мне необходимо последовательно.
PPS: Я не программист, так что сильно не ругайте за код, просто приходится параллельно выполнять еще и такие задачи. Прислушаюсь к хорошим советам по улучшению кода. |
)