这是一个创建于 2694 天前的主题，其中的信息可能已经有所发展或是发生改变。
public static void register(Class<? extends Event> eventClass, Subscriber subscriber) { CopyOnWriteArraySet<Subscriber> set = SUBSCRIBER_MAP.get(eventClass); if (set == null) { set = new CopOnWriteArraySet<Subscriber>(); // 这里有点意思,判断了两次是不是 null,这样能够线程安全吗? CopyOnWriteArraySet<Subscriber> old = SUBSCRIBER_MAP.putIfAbsent(eventClass, set); if (old != null) { set = old; } } set.add(subscriber); if (LOGGER.isDebugEnabled()) { LOGGER.debug("Register subscriber: {} of event: {}.", subscriber, eventClass); } } 两次判断 null,是不是从线程安全的角度考虑的
9 条回复
 | 1 raynor2011 2018-05-27 17:39:48 +08:00 没法保证，old != null 和 set = old 中间一样有可能被另一个线程改写 |
 | 2 MrXiong OP @raynor2011 那为什么这么做呢 |
| 3 MrXiong OP @raynor2011 我看了代码没有别的地方改写这个 Set |
 | 4 neoblackcap 2018-05-27 17:50:24 +08:00 没法保证线程安全，想安全，老实上锁 |
| 5 MrXiong OP 补充:map 是 ` private final static ConcurrentHashMap<Class<? extends Event>, CopyOnWriteArraySet<Subscriber>> SUBSCRIBER_MAP = new ConcurrentHashMap<Class<? extends Event>, CopyOnWriteArraySet<Subscriber>>();` |
| 6 raynor2011 2018-05-27 17:51:26 +08:00 @MrXiong 两个线程同时调用 register 就可能出错 |
 | 7 alamaya 2018-05-27 17:55:49 +08:00  1 ConcurrentHashMap 本来就是线程安全，这里 putIfAbsent 就是为了保证只有一个初始化的 set 被装入 map 里 |
| 8 raynor2011 2018-05-27 18:08:37 +08:00 @alamaya 但是 old ！= null 的判断，和把对象加入 set， 这一步不是原子的，并不能保证线程安全， 正确的方案应该是提供一个线程安全的 add_new 方案，这样如果之前以及初始化过了，就不会再添加一遍 |
| 9 MrXiong OP @raynor2011 由于没有 remove 方法所以一旦 put 到 map 中就不会删除,所以下面的 old ！= null 的判断不需要保证安全性,只需要保证只有一个初始化的 set 放到 map 里就行,因此这个方法是没有问题的 |
Select Language