异步编程求助：依赖任务执行时重复创建记录问题排查

你遇到的核心问题是当多个异步操作同时处理同一个ID时，它们的GetRecord调用可能都会返回null，导致重复执行CreateRecord——不管是用Task.Run(...).Result强行同步并行，还是如果第三方服务存在一致性延迟，串行处理也可能出现类似问题。下面给出几种针对性的解决方案：

方案1：先对ID列表去重（最适配你的固定列表场景） #

既然你的输入列表是固定的[2, 1, 3, 3, 4, 5]，最直接的方式是先对ID去重，从根源上避免重复处理同一个ID：

var uniqueIDs = IDs.Distinct().ToList();
foreach(var id in uniqueIDs) {
    var record = await GetRecord(id);
    if (record == null) {
        await CreateRecord(id);
    }
}

这种写法简单高效，完美适配你当前的静态列表需求。

方案2：严格串行处理（适配动态ID流场景） #

如果你的ID列表是实时动态生成的（比如不断流入的请求），没法提前去重，那保持严格的串行处理是最稳妥的——同一时间只有一个ID在被处理，前一个ID的CreateRecord完成后，后续同ID请求的GetRecord就能查到已创建的记录：

// 确保每次await都等待上一个任务完成，真正串行执行
foreach(var id in IDs) {
    var record = await GetRecord(id);
    if (record == null) {
        // 可选：加入重试逻辑，确保创建成功再继续
        bool createdSuccessfully = await CreateRecord(id);
        // while (!createdSuccessfully) { /* 重试逻辑 */ }
    }
}

⚠️ 注意：你之前尝试的Task.Run(async () => await GetRecord(id)).Result是错误写法——这种方式会强行阻塞异步操作，且循环中多次调用会导致多个任务并行执行，这正是重复创建的根源。

方案3：并行处理+同ID锁控（高性能场景） #

如果需要并行处理不同ID以提升效率，但又要避免同ID的并发冲突，可以用线程安全的锁容器控制每个ID的访问：

// 用ConcurrentDictionary存储每个ID对应的锁对象，确保线程安全
private readonly ConcurrentDictionary<int, object> _idLocks = new ConcurrentDictionary<int, object>();

public async Task ProcessIDs(List<int> IDs) {
    // 并行处理不同ID，同ID操作被锁串行化
    await Task.WhenAll(IDs.Select(async id => {
        // 获取当前ID的锁对象，不存在则新建
        var lockObj = _idLocks.GetOrAdd(id, new object());
        lock(lockObj) {
            var record = await GetRecord(id);
            if (record == null) {
                await CreateRecord(id);
            }
            // 处理完后移除锁对象，避免长期占用内存（可选）
            _idLocks.TryRemove(id, out _);
        }
    }));
}

这个方案兼顾了性能和一致性：不同ID可以并行处理，同一个ID的操作则被强制串行，不会出现“同时查不到记录→同时创建”的情况。

额外优化建议 #

• 复用HttpClient：你的GetRecord和CreateRecord方法每次都新建HttpClient，这会导致socket资源耗尽。建议复用HttpClient（比如用静态实例或依赖注入的单例）。
• 处理第三方服务一致性延迟：如果第三方服务存在最终一致性问题（比如CreateRecord成功后，GetRecord需要几秒才能查到），可以在CreateRecord成功后加一段短暂延迟，或在GetRecord返回null时重试几次再执行创建操作。

内容的提问来源于stack exchange，提问作者blue piranha