关于 PR #10631 的 CI 和 Review

[somak2kai]

关于 PR #10631 的 CI 和 Review

大家好，想请大家帮忙看一下这个 PR：

• PR: [ISSUE-10630] Fixes potential data race and TOCTOU inconsistency foun… #10631
• Issue: [Bug] A potential data race and TOCTOU inconsistency found in org.apache.rocketmq.client.impl.consumer.DefaultLitePullConsumerImpl #10630

这个 PR 主要修复 DefaultLitePullConsumerImpl.taskTable 的并发问题。

目前 taskTable 会在以下几个方法中进行修改：

• updatePullTask
• updateAssignPullTask
• removePullTask

其中存在 check-then-act 的并发风险，例如：

if (!taskTable.containsKey(key)) {
    taskTable.put(key, task);
}

containsKey 和 put 之间没有同步保护，并发情况下可能产生 race condition。

这次修改统一使用：

synchronized (this.taskTable) {
    // check and update taskTable
}

保证对 taskTable 的检查和修改是原子的。

另外增加了 DefaultLitePullConsumerImplTaskTableRaceTest，用于复现和验证这个并发问题。

目前代码已经提交，想请 committer 帮忙触发一下 CI，如果方便的话也希望帮忙 Review 一下。

如果实现方式有问题，欢迎直接指出，我可以继续修改。

谢谢！