|
1 | 1 | package info.xiaomo.server.event; |
2 | 2 |
|
3 | | -import org.slf4j.Logger; |
4 | | -import org.slf4j.LoggerFactory; |
5 | | - |
6 | 3 | import java.util.ArrayList; |
7 | 4 | import java.util.HashMap; |
8 | 5 | import java.util.List; |
9 | 6 | import java.util.Map; |
| 7 | +import org.slf4j.Logger; |
| 8 | +import org.slf4j.LoggerFactory; |
10 | 9 |
|
11 | 10 | /** |
12 | 11 | * 由于事件都是预先注册好的,所以这里不考虑多线程问题,不允许在游戏运行过成中动态添加观察者 |
13 | 12 | * |
14 | 13 | * @author 张力 |
15 | | - * @date 2014-12-6 上午11:19:00 |
| 14 | + * 2014-12-6 上午11:19:00 |
16 | 15 | */ |
17 | 16 | public class EventUtil { |
18 | 17 |
|
19 | | - /** |
20 | | - * 游戏启动就初始化的监听者列表 |
21 | | - */ |
22 | | - private final static Map<EventType, List<IEventListener>> PREPARED_LISTENERS = new HashMap<>(10); |
23 | | - |
24 | | - /** |
25 | | - * 游戏运行中动态添加的监听者列表 |
26 | | - */ |
27 | | - private final static Logger LOGGER = LoggerFactory.getLogger(EventUtil.class); |
28 | | - |
29 | | - static void addListener(IEventListener listener, EventType type) { |
30 | | - List<IEventListener> listenerList = PREPARED_LISTENERS.computeIfAbsent(type, k -> new ArrayList<>()); |
31 | | - listenerList.add(listener); |
32 | | - } |
33 | | - |
34 | | - public static void fireEvent(EventType type) { |
35 | | - fireEvent(type, null); |
36 | | - } |
37 | | - |
38 | | - public static void fireEvent(EventType type, Object obj) { |
39 | | - |
40 | | - List<IEventListener> listenerList = PREPARED_LISTENERS.get(type); |
41 | | - if (listenerList != null) { |
42 | | - for (IEventListener listener : listenerList) { |
43 | | - try { |
44 | | - listener.update(type, obj); |
45 | | - } catch (Exception e) { |
46 | | - LOGGER.error("事件执行错误", e); |
47 | | - } |
48 | | - } |
49 | | - } |
50 | | - } |
| 18 | + /** |
| 19 | + * 游戏启动就初始化的监听者列表 |
| 20 | + */ |
| 21 | + private final static Map<EventType, List<IEventListener>> PREPARED_LISTENERS = new HashMap<>(10); |
| 22 | + |
| 23 | + /** |
| 24 | + * 游戏运行中动态添加的监听者列表 |
| 25 | + */ |
| 26 | + private final static Logger LOGGER = LoggerFactory.getLogger(EventUtil.class); |
| 27 | + |
| 28 | + static void addListener(IEventListener listener, EventType type) { |
| 29 | + List<IEventListener> listenerList = PREPARED_LISTENERS.computeIfAbsent(type, k -> new ArrayList<>()); |
| 30 | + listenerList.add(listener); |
| 31 | + } |
| 32 | + |
| 33 | + public static void fireEvent(EventType type) { |
| 34 | + fireEvent(type, null); |
| 35 | + } |
| 36 | + |
| 37 | + public static void fireEvent(EventType type, Object obj) { |
| 38 | + |
| 39 | + List<IEventListener> listenerList = PREPARED_LISTENERS.get(type); |
| 40 | + if (listenerList != null) { |
| 41 | + for (IEventListener listener : listenerList) { |
| 42 | + try { |
| 43 | + listener.update(type, obj); |
| 44 | + } catch (Exception e) { |
| 45 | + LOGGER.error("事件执行错误", e); |
| 46 | + } |
| 47 | + } |
| 48 | + } |
| 49 | + } |
51 | 50 |
|
52 | 51 |
|
53 | 52 | } |
0 commit comments