zk中ClientCnxn的EventThread有什么作用

这篇文章主要讲解了"zk中ClientCnxn的EventThread有什么作用"，文中的讲解内容简单清晰，易于学习与理解，下面请大家跟着小编的思路慢慢深入，一起来研究和学习"zk中ClientCnxn的EventThread有什么作用"吧！

EventThread 处理event 回调Callback（处理结果） packet

UML

将事件和相关监听列表加入到等待队列中private void queueEvent(WatchedEvent event, Set materializedWatchers) {    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);}处理packetpublic 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有什么作用这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是，小编将为大家推送更多相关知识点的文章，欢迎关注！