zk中ClientCnxn的EventThread有什么作用
这篇文章主要讲解了“zk中ClientCnxn的EventThread有什么作用”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“zk中ClientCnxn的EventThread有什么作用”吧!
创新互联专注于城中企业网站建设,成都响应式网站建设公司,商城网站建设。城中网站建设公司,为城中等地区提供建站服务。全流程按需设计网站,专业设计,全程项目跟踪,创新互联专业和态度为您提供的服务
EventThread 处理event 回调Callback(处理结果) packet
UML
将事件和相关监听列表加入到等待队列中 private void queueEvent(WatchedEvent event, SetmaterializedWatchers) { if (event.getType() == EventType.None && sessionState == event.getState()) { return; } sessionState = event.getState(); final Set watchers; if (materializedWatchers == null) { // materialize the watchers based on the event watchers = watcher.materialize(event.getState(), event.getType(), event.getPath()); } else { watchers = new HashSet (); watchers.addAll(materializedWatchers); } //设置watcherSetEventPair WatcherSetEventPair pair = new WatcherSetEventPair(watchers, event); // queue the pair (watch set & event) for later processing waitingEvents.add(pair); } 处理packet public void queuePacket(Packet packet) { if (wasKilled) { synchronized (waitingEvents) { if (isRunning) { waitingEvents.add(packet); } else { processEvent(packet); } } } else { waitingEvents.add(packet); } }
感谢各位的阅读,以上就是“zk中ClientCnxn的EventThread有什么作用”的内容了,经过本文的学习后,相信大家对zk中ClientCnxn的EventThread有什么作用这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!
分享标题:zk中ClientCnxn的EventThread有什么作用
转载来源:http://myzitong.com/article/gjpijh.html