zk中ClientCnxn的EventThread有什么作用

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

创新互联专注于城中企业网站建设,成都响应式网站建设公司,商城网站建设。城中网站建设公司,为城中等地区提供建站服务。全流程按需设计网站,专业设计,全程项目跟踪,创新互联专业和态度为您提供的服务

EventThread 处理event 回调Callback(处理结果) packet

UML

zk中ClientCnxn的EventThread有什么作用

将事件和相关监听列表加入到等待队列中
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有什么作用这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是创新互联,小编将为大家推送更多相关知识点的文章,欢迎关注!


分享标题:zk中ClientCnxn的EventThread有什么作用
转载来源:http://myzitong.com/article/gjpijh.html