如何在python中实现capl语言里的回调函数(推荐)

on message 0x11
{
  byte msg_bytes[8];
  int i;
  for(i=0;i<8;i++)
  {
    msg_bytes[i] = this.byte(i);
  }
}  

def OnEvent_1():
    print("callback up")

def TriggerFunc(fn):
    fn()

if __name__ == "__main__":
    TriggerFunc(OnEvent_1)

import time
import threading

def OnEvent_1(): # 事件函数1
    print("OnEvent_1 up")

def OnEvent_2(): # 事件函数2
    print("OnEvent_2 up")

class RegistEvents(): # 全局变量，存入事件函数指针和对应的触发条件
    registEvents = {} # 存入key:value，key是事件函数指针，value是触发此事件函数的条件

def TriggerFunc(): # 异步函数，用来监测触发条件是否触发，如果触发就执行对应的函数
    currentRegistEvents = {} # 当前的事件和对应条件存入这里
    for event in RegistEvents.registEvents.keys():
        currentRegistEvents[event] = RegistEvents.registEvents[event]
    while True:
        time.sleep(0.01)
        for event in RegistEvents.registEvents.keys():
            if currentRegistEvents[event] != RegistEvents.registEvents[event]:
                event()
                currentRegistEvents[event] = RegistEvents.registEvents[event]

if __name__ == "__main__":
    RegistEvents.registEvents[OnEvent_1] = 0 # 对事件函数OnEvent_1和它的条件进行委托
    RegistEvents.registEvents[OnEvent_2] = 0 # 对事件函数OnEvent_2和它的条件进行委托
    t = threading.Thread(target = TriggerFunc) # 对监测触发条件的函数创建线程，异步执行
    t.start()
    time.sleep(1)
    RegistEvents.registEvents[OnEvent_1] = 1 # 触发条件本来是0，现在设置为1
    RegistEvents.registEvents[OnEvent_2] = 1
    time.sleep(1)
    RegistEvents.registEvents[OnEvent_1] = 2 # 触发条件本来是1，现在设置为2
    RegistEvents.registEvents[OnEvent_2] = 2