
等异步执行完成后,封装response

刷盘和同步线程同时成功后,执行里面的逻辑


对于同步刷盘,我们看下这个类GroupCommitService,只要flushedWhere大于nextoffset才说明刷盘完成,不然就一直刷,直到满足。

我们看看这个类GroupCommitService,当刷新成功后,则GroupCommitRequest flushOKFuture设置为complete。
等异步执行完成后,封装response
刷盘和同步线程同时成功后,执行里面的逻辑
对于同步刷盘,我们看下这个类GroupCommitService,只要flushedWhere大于nextoffset才说明刷盘完成,不然就一直刷,直到满足。
我们看看这个类GroupCommitService,当刷新成功后,则GroupCommitRequest flushOKFuture设置为complete。
本文标题:消息同步、异步刷盘
本文链接:https://www.haomeiwen.com/subject/chkliltx.html
网友评论