zk中CommitProcessor的作用是什么

本篇文章給大家分享的是有關zk中CommitProcessor的作用是什么，小編覺得挺實用的，因此分享給大家學習，希望大家閱讀完這篇文章后可以有所收獲，話不多說，跟著小編一起來看看吧。

CommitProcessor用來處理提交的請求

CommitProcessor extends Thread implements RequestProcessor

UML關系圖

內部類

CommitWorkRequest

屬性

構造方法
public CommitProcessor(RequestProcessor nextProcessor, String id, boolean matchSyncs) {
    super("CommitProcessor:" + id);
    this.nextProcessor = nextProcessor;
    this.matchSyncs = matchSyncs;
}


是否正在處理請求
private boolean isProcessingRequest() {
    return numRequestsProcessing.get() != 0;
}


是否需要commit
protected boolean needCommit(Request request) {
    switch (request.type) {
    case OpCode.create:
    case OpCode.create2:
    case OpCode.createTTL:
    case OpCode.createContainer:
    case OpCode.delete:
    case OpCode.deleteContainer:
    case OpCode.setData:
    case OpCode.reconfig:
    case OpCode.multi:
    case OpCode.setACL:
    case OpCode.check:
        return true;
    case OpCode.sync:
        return matchSyncs;
    case OpCode.createSession:
    case OpCode.closeSession:
        return !request.isLocalSession();
    default:
        return false;
    }
}

以上就是zk中CommitProcessor的作用是什么，小編相信有部分知識點可能是我們日常工作會見到或用到的。希望你能通過這篇文章學到更多知識。更多詳情敬請關注億速云行業資訊頻道。