tsgmq
Results
1
comments of
tsgmq
看了下源码,snapshot也是往taskQueue的ringBuffer中提交了Task,由于状态机中的Task是顺序onApply的,这样的话如果是单线程执行,就不会出现snapshot的过程中有其他logEntry处理,就不会改变状态机中的其他对象的值了吧 @Override public boolean onSnapshotSave(final SaveSnapshotClosure done) { return enqueueTask((task, sequence) -> { task.type = TaskType.SNAPSHOT_SAVE; task.done = done; }); }