概念

  • EventMesh 组件用于消息的订阅和发布。在多线程中可用于，多个线程多个消息的解耦处理，通过定义不同的类型的 topic 用于处理不同的事务，任何线程可以随时通过 publish 来处理该消息。
  • 该组件只能一对一或者多对一通信，即一个topic同时只能一个订阅者，最后一个订阅的会挤掉其他订阅者
  • 自己导入下载
  • EventMesh

例子1

  • 该示例线程通过订阅 topic，A、B 线程分别向其订阅 topic 发送订阅消息处理
  1. # 该示例线程通过订阅 topic，A、B 线程分别向其订阅 topic 发送订阅消息处理。
  2. import _thread
  3. import utime
  4. from usr import EventMesh
  6. def callback_A(topic, msg):
  7.     print("topic = {} msg = {}".format(topic, msg))
  9. def callback_B(topic, msg):
  10.     print("topic = {} msg = {}".format(topic, msg))
  12. # 线程 B 函数入口，订阅 EventMesh/thread_B topic并定时3秒发送消息到EventMesh/thread_A topic。
  13. def thread_entry_B(id):
  14.     EventMesh.subscribe("EventMesh/thread_B", callback_B)
  15.     while True:
  16.         EventMesh.publish_sync("EventMesh/thread_A", "this is thread B msg")
  17.         utime.sleep(3)
  19. # 线程 A 函数入口，订阅 EventMesh/thread_A topic并定时3秒发送消息到EventMesh/thread_B topic。
  20. def thread_entry_A(id):
  21.     EventMesh.subscribe("EventMesh/thread_A", callback_A)
  22.     while True:
  23.         EventMesh.publish_sync("EventMesh/thread_B", "this is thread A msg")
  24.         utime.sleep(3)
  26. # 创建线程A、B。
  27. _thread.start_new_thread(thread_entry_A, ('A',))
  28. _thread.start_new_thread(thread_entry_B, ('B',))

例子2

  1. # 该示例线程 A、B 通过订阅同一 topic，EventMesh 一个 topic 只能一个订阅，B 最后订阅，会直接挤掉 A 的订阅，只有 B 线程能收到该 topic 消息。
  2. import _thread
  3. import utime
  4. from usr import EventMesh
  6. def callback_A(topic, msg):
  7.     print("callback_A topic = {} msg = {}".format(topic, msg))
  9. def callback_B(topic, msg):
  10.     print("callback_B topic = {} msg = {}".format(topic, msg))
  12. # 线程 B 函数入口，订阅 EventMesh/multithread topic。
  13. def thread_entry_B(id):
  14.     EventMesh.subscribe("EventMesh/multithread", callback_B)
  15.     while True:
  16.         utime.sleep(10)
  18. # 线程 A 函数入口，订阅 EventMesh/multithread topic。
  19. def thread_entry_A(id):
  20.     EventMesh.subscribe("sysbus/multithread", callback_A)
  21.     while True:
  22.         utime.sleep(10)
  24. # 创建线程A、B。
  25. _thread.start_new_thread(thread_entry_A, ('A',))
  26. _thread.start_new_thread(thread_entry_B, ('B',))
  28. # 主线程间隔3秒发布消息到 EventMesh/multithread topic。
  29. while True:
  30.     EventMesh.publish_sync("EventMesh/multithread", "EventMesh broadcast conntent!")
  31.     utime.sleep(3)