我正在尝试为正在构建的Android应用程序创建轻量,线程安全的应用程序内发布/订阅机制。我的基本方法是跟踪IEventSubscriber<T>每个事件类型T 的列表,然后能够通过传递类型T的有效负载来将事件发布到订阅对象。
我使用通用方法参数来(确保)确保以类型安全的方式创建订阅。因此,我非常确定,当我要从发布地图中获取订阅者列表时,是时候发布一个可以将其强制转换为的列表的事件了IEventSubscriber<T>,但是,这会生成未经检查的强制转换警告。
我的问题:
IEventSubscriber<T>?代码(Java 1.6):
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ConcurrentMap;
import java.util.concurrent.CopyOnWriteArraySet;
public class EventManager {
private ConcurrentMap<Class, CopyOnWriteArraySet<IEventSubscriber>> subscriptions =
new ConcurrentHashMap<Class, CopyOnWriteArraySet<IEventSubscriber>>();
public <T> boolean subscribe(IEventSubscriber<T> subscriber,
Class<T> eventClass) {
CopyOnWriteArraySet<IEventSubscriber> existingSubscribers = subscriptions.
putIfAbsent(eventClass, new CopyOnWriteArraySet<IEventSubscriber>());
return existingSubscribers.add(subscriber);
}
public <T> boolean removeSubscription(IEventSubscriber<T> subscriber,
Class<T> eventClass) {
CopyOnWriteArraySet<IEventSubscriber> existingSubscribers =
subscriptions.get(eventClass);
return existingSubscribers == null || !existingSubscribers.remove(subscriber);
}
public <T> void publish(T message, Class<T> eventClass) {
@SuppressWarnings("unchecked")
CopyOnWriteArraySet<IEventSubscriber<T>> …Run Code Online (Sandbox Code Playgroud)