快速响应由另一个线程更改的变量的最佳方法

Question

我编写了一个程序来使用每 10 毫秒通过 UDP 数据包发送给它的数据。我正在使用单独的线程，因为运行逻辑来处理数据可能需要不同的时间，如果超过 10 毫秒，我只希望它处理最近收到的数据报。我目前正在运行一个 while 循环，并通过 time.sleep(0.001) 每毫秒检查一次新报价。我刚刚了解到，在 windows server 2019 操作系统上处理这个 time.sleep() 实际上最多需要 16 毫秒，它会延迟一切。我可以只使用 pass 而不是 time.sleep ，但这最终会使用过多的 CPU（我正在运行该程序的多个实例）。有没有办法让程序暂停并在继续之前等待 maindata.newquote == True ？诀窍是我希望它能够非常快速地响应（不到一毫秒），而不是等待下一个 Windows 定时器中断。

class maindata:
  newquote = False
  quote = ''
  

def startquotesUDP(maindata,myaddress,port):
  UDPServerSocket = socket(family=AF_INET, type=SOCK_DGRAM)
  UDPServerSocket.bind((myaddress, port))  
  while True:
    bytesAddressPair = UDPServerSocket.recvfrom(bufferSize)
    #parse raw data
    maindata.quote = parsed_data
    maindata.newquote = True

threading.Thread(target=startquotesUDP,args=(maindata,address,port,)).start()

while True:
  if maindata.newquote == False:
    time.sleep(0.001)               #This is what I want to improve
  else:
    #process maindata.quote
    maindata.newquote = False

Answer 1

我的答案与上面的@balmy 相同，但我什至不会打扰信号量。

生产者只是写入队列

while True:
    result = ...
    queue.put(result)
    sleep as necessary

接收者可以通过做得到每一个结果

while True:
    result = queue.get()
    handle result

如果您只想查看生产者发送的最新结果，以防自上次查看以来它已发送多个结果，那么：

while True:
    result = queue.get()
    while not queue.empty():
        result = queue.get()
    handle result