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);
}


处理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有什么作用这一问题有了更深刻的体会，具体使用情况还需要大家实践验证。这里是创新互联，小编将为大家推送更多相关知识点的文章，欢迎关注！