Есть поток, который в цикле ожидает данные от ком-порта (или любого другого интерфейса) и при их поступлении вызывает событие OnFrameReceived(...)
. Мне нужно написать блокирующий метод SendAndWaitReply(...)
, который отправит данные по ком-порту и будет ждать ответа (события OnFrameReceived
) или таймаута операции (если ответ не придет).
Подскажите, как организовать синхронизацию потока чтения и потока, отправляющего команду?
public class Device
{
Connection connection = new Connection(...);
public Device()
{
connection.FrameReceived += Connection_FrameReceived;
}
// Отправить пакет и дождаться ответа/таймаута
public void SendAndWaitReply(ITxFrame frame)
{
bool timeout = false;
// Отправить пакет и заблокировать поток до наступления таймаута или приема ответа
if(timeout)
{
throw new TimeoutException();
}
}
// Событие приема пакета
private void Connection_FrameReceived(object sender, RxFrame frame)
{
// Разблокировать поток, ожидающий приема пакета
// Обработка принятого пакета
}
}