唤醒沉睡的线程的最好方法?

2022-05-23 00:00:00 python multithreading events sleep

问题描述

我的局域网上有一台仪器,每隔5-10ms发送一次UDP数据包。在我的应用程序中,我有一个读取器线程,它在套接字启动时分配一个具有大缓冲区的套接字,然后进入无限循环以读取累积的包,解析它们,将它们写入假脱机程序,然后休眠半秒(time.sleep(0.500))。

我有几个懒惰的数据使用者,其中大多数进行存档或生成被动统计数据。但有一个消费者(用于显示)需要最新数据,并且需要在查询假脱机程序之前唤醒休眠的读取器(以读取套接字)。

唤醒休眠线程的最佳方法是什么?

(或者,有没有更好的方法让线程休眠,更容易唤醒?)


解决方案

我没有注意到threading.Condition.Wait()有一个可选的超时参数!

答案是create a condition object并将其wait()方法与可选的超时一起使用,而不是time.sleep()。如果需要在超时之前唤醒线程,请调用Condition对象的notify()方法。

相关文章