非异步环境下Swift Task代码块调用的序列化问题

核心问题出在你调用函数的顺序和Task实际进入序列化队列的时机没对齐——哪怕你在Task内部做了序列化，多个线程调用函数时，可能因为调度问题让后调用的函数先把Task塞进队列，导致顺序错乱。下面给几个靠谱的纯异步解决方案：

方案1：维护串行任务队列（最直接） #

用一个全局的Task变量记录当前执行的"尾巴"，每次调用函数时，把当前任务追加到这个尾巴后面，确保前一个任务完全结束后再执行下一个。示例代码（以C#为例）：

// 初始化一个已完成的任务作为队列起点
private Task _executionQueue = Task.CompletedTask;

public async Task YourTargetFunction(int number)
{
    // 将当前任务加入串行队列，等待前序任务完成
    _executionQueue = RunInSequence(_executionQueue, number);
    // 等待当前任务执行完成（可选，根据需求决定是否需要等待）
    await _executionQueue;
}

private async Task RunInSequence(Task previousTask, int number)
{
    // 先等前一个任务做完
    await previousTask;
    // 这里放你原来函数里的异步逻辑
    await Task.Delay(100); // 模拟耗时操作
    Console.WriteLine(number);
}

这个方案的核心是调用顺序直接决定执行顺序，不会出现插队，所有任务严格按调用先后排队执行。

方案2：正确使用信号量（并非混合的问题） #

之前用信号量出错，大概率是只在Task内部加了锁，而没把整个函数的执行流程包裹进去。只要确保信号量保护的是整个函数的异步逻辑，就能保证串行：

private readonly SemaphoreSlim _serialSemaphore = new SemaphoreSlim(1, 1);

public async Task YourTargetFunction(int number)
{
    await _serialSemaphore.WaitAsync();
    try
    {
        // 你的异步逻辑全放在这里面
        await Task.Delay(100);
        Console.WriteLine(number);
    }
    finally
    {
        _serialSemaphore.Release();
    }
}

WaitAsync()会按调用顺序排队等待信号量，只要整个异步流程都在信号量的保护范围内，就不会出现顺序错乱。

方案3：用Channel实现异步串行队列 #

如果需要更灵活的生产者-消费者模式，官方的Channel是比AsyncStream更可靠的选择，它天然保证写入顺序等于处理顺序：

// 创建单消费者的无界通道，确保串行处理
private readonly Channel<int> _taskChannel = Channel.CreateUnbounded<int>(new UnboundedChannelOptions
{
    SingleReader = true,
    SingleWriter = false
});

// 初始化消费者，启动后持续处理队列
public YourClassConstructor()
{
    _ = ProcessTasksFromChannel();
}

public async Task YourTargetFunction(int number)
{
    // 把任务参数写入通道，按调用顺序排队
    await _taskChannel.Writer.WriteAsync(number);
}

private async Task ProcessTasksFromChannel()
{
    // 按写入顺序逐个处理
    await foreach (var number in _taskChannel.Reader.ReadAllAsync())
    {
        await Task.Delay(100);
        Console.WriteLine(number);
    }
}

为什么之前的方案会出错？ #

• 你之前参考的Task内部序列化，可能是用了共享变量直接赋值（比如_serialTask = _serialTask.ContinueWith(...)），多线程调用时会出现竞态条件，导致某个任务被覆盖跳过；
• AsyncStream如果是自己实现的IAsyncEnumerable，可能没正确处理同步上下文或排队逻辑，导致枚举顺序和生产顺序不一致，而Channel是官方优化过的异步队列，不存在这个问题。

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