EventBus是一个Android事件发布/订阅框架,它简化了组件之间的通信,以下是一个简单的EventBus源码实现:
import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.CopyOnWriteArrayList; public class EventBus { private static EventBus instance; private ConcurrentHashMap<String, CopyOnWriteArrayList<EventListener>> listenersMap; private EventBus() { listenersMap = new ConcurrentHashMap<>(); } public static EventBus getInstance() { if (instance == null) { synchronized (EventBus.class) { if (instance == null) { instance = new EventBus(); } } } return instance; } public void register(String eventType, EventListener listener) { if (!listenersMap.containsKey(eventType)) { listenersMap.put(eventType, new CopyOnWriteArrayList<>()); } listenersMap.get(eventType).add(listener); } public void unregister(String eventType, EventListener listener) { if (listenersMap.containsKey(eventType)) { listenersMap.get(eventType).remove(listener); } } public void post(String eventType, Object event) { if (listenersMap.containsKey(eventType)) { for (EventListener listener : listenersMap.get(eventType)) { listener.onEvent(event); } } } public interface EventListener { void onEvent(Object event); } }
这个简单的EventBus实现包括以下几个部分:
1、EventBus
类:单例模式,确保整个应用只有一个EventBus实例。
2、listenersMap
:一个线程安全的ConcurrentHashMap,用于存储事件类型和对应的监听器列表。
3、register
方法:注册监听器到指定的事件类型,如果该事件类型不存在,则创建一个新的监听器列表并将其添加到map中。
4、unregister
方法:从指定的事件类型中注销监听器。
5、post
方法:发布事件到指定的事件类型,通知所有注册的监听器。
6、EventListener
接口:定义了一个回调方法onEvent
,用于处理接收到的事件。
这个实现仅作为示例,实际项目中可能会有更多的功能和优化,例如支持泛型、注解等。
原创文章,作者:未希,如若转载,请注明出处:https://www.kdun.com/ask/1083988.html
本网站发布或转载的文章及图片均来自网络,其原创性以及文中表达的观点和判断不代表本网站。如有问题,请联系客服处理。
发表回复