美文网首页
消息同步、异步刷盘

消息同步、异步刷盘

作者: Britney_z | 来源:发表于2021-08-23 14:54 被阅读0次

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

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

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

我们看看这个类GroupCommitService,当刷新成功后,则GroupCommitRequest flushOKFuture设置为complete。

相关文章

网友评论

      本文标题:消息同步、异步刷盘

      本文链接:https://www.haomeiwen.com/subject/chkliltx.html