org.eclipse.osgi中的copyOnWrite和eventManager
本文以eclipse 4.20为参考.
读写分离的CopyOnWrite container
每当生产者向container添加和删除item时, copyOnWrite container都重新拷贝生成新版collection, 确保消费者从container取得的旧版collection不被影响. 也就是说, 生产者每次增删item时, container生成新的快照snapshot, 新的快照不会污染旧的快照, 原则上要求快照一经生成就不再变动. 这样消费者取得的旧快照不会被后面的消费者改写污染, 可以放心处理. 从而实现了同步上的读写分离.
为了解决多生产者冲突, 通常增删采用synchronized限定, 而消费者这里不会进行该限定, 否则就失去了copyOnWrite的效率意义.
copyOnWrite能够成立的一个假设是container生成新快照与读取旧快照不会互相干扰. 所谓干扰是指新旧快照间的互相污染, 而这通常依赖于赋值操作的原子性.
多消费者情形要避免彼此间所持快照的干扰. 这是要注意的地方, 也是选取copyOnWrite container这个解决方案的一个考虑点.
采用快照, 导致需要数据的整体复制, 故copyOnWrite不适用于高频和大容量快照的场合.
eclipse中将copyOnWrite用到了向listeners分发event的场景, 而listeners的增删一者不频繁, 二者数据量较小.
支持同步和异步分发事件的eventManager机制
该机制实现了向一组eventListener分发event, 采用异步或同步方式. 这里着重简记async dispatch情形.
整个核心是两个类EventManager和ListenerQueue.
EventManager做的工作包括,
- 创建一个event thread, 会在该event thread中执行dipatchEvent操作, 即async dispatch.
- 提供一个FIFO queue.
- 发起者listenerQueue通过postEvent(),将与dispatchEvent相关的信息, 例如eventListener, listenerObj, dispatcher, action,和eventObj打包成一个item压入FIFO quque中.
- event thread从FIFO queue中取出item执行分发.
ListenerQueue持有一个CopyOnWriteIdentityMap queue, 并持有eventManager的reference. 操作可分成几步,
- listenerQueue关联eventManager
- 将listeners添加到listenerQueue中
- 使用dispatchEventAsynchronous()或dispatchEventSynchronous()分发event.
EquinoxEventPublisher
使用EventManager的实现了BundleEvent和FrameworkEvent的分发. SynchronousBundleListener采用sync dispatch, 而其它(FrameworkListener,BundleListener)则使用async dispatch.
一花一世界 2021/8/2
|