zk中ClientCnxn的EventThread有什么作用

這篇文章主要講解了“zk中ClientCnxn的EventThread有什么作用”，文中的講解內(nèi)容簡單清晰，易于學(xué)習(xí)與理解，下面請大家跟著小編的思路慢慢深入，一起來研究和學(xué)習(xí)“zk中ClientCnxn的EventThread有什么作用”吧！

EventThread 處理event 回調(diào)Callback（處理結(jié)果） packet

UML

將事件和相關(guān)監(jiān)聽列表加入到等待隊(duì)列中
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);
    }
    //設(shè)置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有什么作用”的內(nèi)容了，經(jīng)過本文的學(xué)習(xí)后，相信大家對(duì)zk中ClientCnxn的EventThread有什么作用這一問題有了更深刻的體會(huì)，具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是億速云，小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章，歡迎關(guān)注！