17 lines
590 B
Python
17 lines
590 B
Python
class EventBus:
|
|
def __init__(self):
|
|
self.listeners = {} # 管理各种event的订阅情况
|
|
|
|
def subscribe(self, event_type, listener):
|
|
if event_type not in self.listeners:
|
|
self.listeners[event_type] = []
|
|
self.listeners[event_type].append(listener)
|
|
|
|
def publish(self, event_type, data):
|
|
if event_type in self.listeners:
|
|
for listener in self.listeners[event_type]:
|
|
listener(data)
|
|
|
|
# 订阅与发布事件示例
|
|
# event_bus.subscribe('my_event', handle_event)
|
|
# event_bus.publish('my_event', {'key': 'value'}) |