Seastar协程parallel_for_each代码中res的竞态场景是否可能？

先看你提到的这段Seastar代码：

#include <seastar/core/coroutines.hh>
#include <seastar/coroutine/parallel_for_each.hh>

seastar::future<bool> all_exist(std::vector<sstring> filenames) {
    bool res = true;
    co_await seastar::coroutine::parallel_for_each(filenames, [&res] (const seastar::sstring& name) -> seastar::future<> {
        res &= co_await seastar::file_exists(name);
    });
    co_return res;
}

你怀疑这段代码存在竞态条件，认为&=操作的读、写非原子性，加上lambda引用捕获res，会出现多线程并行修改导致的覆盖问题——比如两个协程先后读取res为true，一个写入false后，另一个又写回true。

结论：这个场景不可能发生 #

原因在于Seastar的协程调度模型和parallel_for_each的实现逻辑：

• Seastar采用shard-per-core架构，每个shard绑定一个CPU核心，shard内的协程是协作式调度，而非抢占式多线程。协程只会在主动调用co_await这类让出CPU的操作时才会切换，不存在多个线程同时执行代码路径的情况。
• 这段代码中，所有对res的读写操作都是在同一个线程内串行完成的：每个lambda里的逻辑，从读取res、执行file_exists、到最终修改res，整个流程在协程恢复后是单线程执行的，不会有多个协程同时操作res的情况。

额外建议：优化代码写法 #

虽然这段代码没有竞态问题，但写法不够直观，也无法提前终止（比如一旦发现某个文件不存在，还会继续检查剩下的文件）。更合理的实现方式可以是：

方式1：汇总结果后判断

seastar::future<bool> all_exist(std::vector<sstring> filenames) {
    return seastar::coroutine::parallel_for_each(filenames, [] (const seastar::sstring& name) {
        return seastar::file_exists(name);
    }).then([] (std::vector<bool> results) {
        return std::all_of(results.begin(), results.end(), [] (bool exist) { return exist; });
    });
}

方式2：串行检查+提前退出

如果不需要并行检查（或者希望提前终止），可以直接串行遍历：

seastar::future<bool> all_exist(std::vector<sstring> filenames) {
    for (const auto& name : filenames) {
        if (!co_await seastar::file_exists(name)) {
            co_return false;
        }
    }
    co_return true;
}

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