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有什么作用這一問題有了更深刻的體會，具體使用情況還需要大家實踐驗證。這里是億速云，小編將為大家推送更多相關知識點的文章，歡迎關注！