C#中如何为条件语句引入函数式并行求值？

核心前提：引用透明性是基础 #

在函数式编程里能并行a || b的核心是引用透明性——也就是a和b的计算没有副作用（比如不修改共享状态、不依赖外部可变数据）。在C#里要实现类似逻辑，你必须自己保证条件判断的函数满足这一点，否则并行执行可能会导致不可预测的结果。

没有内置语法糖，但可以基于Task封装实现 #

C#没有像Parallel.For()那样直接适配条件语句的内置方法，但可以通过Task并行API轻松封装出类似ParallelOr/ParallelAnd的逻辑，替代短路求值的||/&&。

1. 基础版：二元条件并行OR #

针对两个条件的场景，用Task.WhenAny实现“只要有一个条件为真就返回”的并行逻辑：

async Task<bool> ParallelOr(Func<bool> condition1, Func<bool> condition2)
{
    // 将两个条件包装成并行任务
    var task1 = Task.Run(condition1);
    var task2 = Task.Run(condition2);

    // 等待第一个完成的任务
    var completedTask = await Task.WhenAny(task1, task2);

    // 第一个完成的条件为真，直接返回（可优化：取消未完成任务）
    if (completedTask.Result)
    {
        return true;
    }

    // 第一个为假，等待另一个任务的结果
    return task1 == completedTask ? await task2 : await task1;
}

2. 通用版：支持多条件并行OR #

如果需要支持任意数量的条件，可以扩展成通用方法，同时加入取消逻辑避免无意义计算：

async Task<bool> ParallelOr(CancellationToken token, params Func<CancellationToken, bool>[] conditions)
{
    if (conditions == null || conditions.Length == 0)
        return false;

    // 启动所有条件的并行任务，绑定取消令牌
    var tasks = conditions
        .Select(c => Task.Run(() => c(token), token))
        .ToList();

    while (tasks.Any())
    {
        var completedTask = await Task.WhenAny(tasks);
        
        // 只要有一个条件为真，触发取消并返回
        if (completedTask.Result)
        {
            token.Cancel();
            return true;
        }

        tasks.Remove(completedTask);
    }

    // 所有条件都为假
    return false;
}

3. 并行AND逻辑（对应&&） #

类似地，你可以封装ParallelAnd——只要有一个条件为假就提前返回：

async Task<bool> ParallelAnd(CancellationToken token, params Func<CancellationToken, bool>[] conditions)
{
    if (conditions == null || conditions.Length == 0)
        return true;

    var tasks = conditions
        .Select(c => Task.Run(() => c(token), token))
        .ToList();

    while (tasks.Any())
    {
        var completedTask = await Task.WhenAny(tasks);
        
        // 只要有一个条件为假，触发取消并返回
        if (!completedTask.Result)
        {
            token.Cancel();
            return false;
        }

        tasks.Remove(completedTask);
    }

    // 所有条件都为真
    return true;
}

关键注意事项 #

• 性能考量：只有当条件判断是耗时操作（比如IO密集型任务、复杂计算）时，并行才有意义。如果只是简单的内存运算，线程切换的开销可能比串行执行更大。
• 严格保证引用透明：条件函数绝对不能有副作用——比如修改类字段、调用有状态的方法等，否则并行执行会引发竞态条件或逻辑错误。
• 取消令牌的必要性：在通用版中加入CancellationToken可以在得到结果后立即终止剩余任务，避免浪费系统资源。

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