如何在循环函数中监听已订阅预设void下的传入事件？

你设想的通过共享变量中转事件数据、循环检测更新的方案是可行的，根据实际场景可以进一步优化，也可以选择更高效的实现方式：

方案1：轮询共享变量方案优化建议 #

如果你的场景对实时性要求不高，或者需要同时在循环内处理其他定时任务，可以沿用这个方案，注意以下几点：

• 保证线程安全：如果事件回调和循环逻辑运行在不同线程，不要直接用普通变量存数据，推荐优先使用语言自带的线程安全队列（比如Python的queue.Queue、Java的BlockingQueue），或者给共享变量加读写锁，避免出现脏读、数据丢失问题
• 避免CPU空转：每次轮询结束后加适当的休眠时间，比如time.sleep(0.01)，可以根据你的实时性要求调整间隔，避免循环占满单核心算力
• 明确退出机制：可以设置独立的全局终止标识，收到退出信号或者处理完目标事件后，修改标识跳出循环，避免死循环

参考伪代码：

# 初始化线程安全队列做数据中转
event_queue = Queue()
exit_flag = False

# 你已订阅的预设回调函数
def subscribed_callback(event_data):
    # 收到事件后存入队列
    event_queue.put(event_data)

# 你的循环逻辑
while not exit_flag:
    if not event_queue.empty():
        # 取出事件数据做后续处理
        current_data = event_queue.get()
        process_event(current_data)
        # 如果只需处理单次事件，处理完可直接break跳出循环
        # break
    # 休眠控制轮询频率
    time.sleep(0.01)

方案2：阻塞式等待（更高效，无空转消耗） #

如果你的循环不需要处理其他定时任务，优先选择阻塞式等待方案，性能比轮询高很多：

• 可以直接用线程安全队列的阻塞读方法，比如current_data = event_queue.get(block=True)，队列空的时候程序会自动阻塞休眠，直到有新事件存入队列才会被唤醒，不需要自己写轮询判断和休眠逻辑
• 也可以用线程同步对象（比如Python的threading.Event、C#的ManualResetEvent），回调函数收到事件后触发同步信号，循环内等待信号触发后再读取事件数据

如果需要兼顾其他定时任务，可以给阻塞方法加超时参数，比如event_queue.get(block=True, timeout=0.1)，超时后自动唤醒执行其他任务，没有事件时也不会消耗过多CPU。

内容的提问来源于stack exchange，提问作者Manolo Martinez