我在c#上写了这段代码
public class SerialClass
{
SerialPort s;
public Serial()
{
InitSerialPort();
s.DataReceived += dataReciver;
}
private void dataReciver(object sender, SerialDataReceivedEventArgs e)
{
lock (obj)
{
while (s.BytesToRead >0)
{
var line = s.ReadLine();
if(line=="hello")
{
Thread.Sleep(500);
s.WriteLine("hello to you friend");
}
else //......
}
}
}
}
当我从序列中得到“你好”时我想在500毫秒后回答“你好朋友”。
我听到这么多,不要在你的代码上使用睡眠..
这里使用睡眠的缺点是什么?如果有更多数据将在serialport上运行,那么新事件将进入dataReciver,因为它将在secondery线程上打开。
那么什么是缺点,什么是没有睡眠的更好/最好的方法来实现它?
我使用锁是因为我想只有1个线程会在这个读数上
如果你做得对,你就不需要锁。
恕我直言,你应该完全避免DataReceived
事件。在SerialPort.BaseStream
中包装StreamReader
,然后以异步方法循环读取。无论如何,我也不会将延迟,异步或其他方式与您的阅读顺序排列。你应该随时准备阅读。
你没有提供真正的代码,所以不可能提供真正的代码解决方案,但是这就是我如何编写你发布的代码:
public class Serial
{
SerialPort s;
public Serial()
{
InitSerialPort();
// Ignore returned task...constructors shouldn't wait. You could store
// the task in a class field, to provide a mechanism to observe the
// receiving state.
Task task = ReceiveLoopAsync();
}
private async Task ReceiveLoopAsync()
{
using (StreamWriter writer = new StreamWriter(s.BaseStream))
using (StreamReader reader = new StreamReader(s.BaseStream))
{
string line;
while ((line = reader.ReadLineAsync()) != null)
{
if (line == "hello")
{
// Ignore returned task...we don't really care when it finishes
Task task = RespondAsync(writer);
}
}
}
}
private async Task RespondAsync(StreamWriter writer)
{
await Task.Delay(500);
writer.WriteLine("hello to you friend");
}
}
我遗漏了异常处理和更强大的任务处理等细节。但以上是基本思路。请注意,所有接收都在单个循环中完成,无需跨线程同步。