zk中ClientCnxn的EventThread有什么作用

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

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

UML

将事件和相关监听列表加入到等待队列中
private void queueEvent(WatchedEvent event, Set<Watcher> materializedWatchers) {
    if (event.getType() == EventType.None && sessionState == event.getState()) {
        return;
    }
    sessionState = event.getState();
    final Set<Watcher> watchers;
    if (materializedWatchers == null) {
        // materialize the watchers based on the event
        watchers = watcher.materialize(event.getState(), event.getType(), event.getPath());
    } else {
        watchers = new HashSet<Watcher>();
        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有什么作用这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是亿速云，小编将为大家推送更多相关知识点的文章，欢迎关注！