You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

无法在lock中使用await,如何保证异步变量和方法不被多线程访问?

你当前的代码首先存在编译错误:C#不允许在lock代码块中使用await关键字,lock底层依赖线程绑定的Monitor实现,await恢复后的执行线程可能和进入锁的线程不一致,会触发锁释放异常。


调整后实现

首先修改私有字段定义:

public const int ThreadLimitMax = 128;
// 替换同步锁为异步互斥锁,支持异步等待场景下的互斥控制
private static readonly SemaphoreSlim _modifyLock = new SemaphoreSlim(1, 1);
private static SemaphoreSlim totalThreadLimiter = new SemaphoreSlim(ThreadLimit, ThreadLimitMax);
        
// 添加volatile修饰符,保证跨线程读取到的始终是最新值
public static volatile int ThreadLimit { get; private set; } = 128;

修改后的SetThreadLimit方法:

public static async Task SetThreadLimit(int max)
{
    // 边界检查无需加锁,ThreadLimitMax为常量不会变更
    if (max > ThreadLimitMax)
        throw new ArgumentOutOfRangeException(nameof(max), $"Cannot have more than {ThreadLimitMax} threads.");
    if (max < 1)
        throw new ArgumentOutOfRangeException(nameof(max), "Cannot have less than 1 threads.");

    // 获取修改互斥锁,保证同一时间只有一个线程执行调整逻辑
    await _modifyLock.WaitAsync().ConfigureAwait(false);
    try
    {
        int difference = Math.Abs(ThreadLimit - max);
        if (max < ThreadLimit)
        {
            // 缩容场景:等待回收差额个许可,所有WaitAsync完成后才会继续执行
            for (int i = 0; i < difference; i++)
            {
                await totalThreadLimiter.WaitAsync().ConfigureAwait(false);
            }
        }
        else if (max > ThreadLimit)
        {
            // 扩容场景:直接释放差额个许可
            totalThreadLimiter.Release(difference);
        }
        // 许可调整完成后再更新线程限制数值
        ThreadLimit = max;
    }
    finally
    {
        // 释放互斥锁,允许后续调整操作执行
        _modifyLock.Release();
    }
}

实现说明

  • 互斥控制:通过初始计数为1的_modifyLock实现修改操作的串行执行,保证调整过程中不会有其他线程修改ThreadLimit,也不会出现多个调整操作并行执行的竞态问题。
  • 缩容等待:降低线程上限时,会等待所有多余的许可被回收完成后才会更新ThreadLimit并返回方法,满足「所有WaitAsync调用完成前方法处于阻塞状态」的需求。
  • 线程安全:SemaphoreSlim本身的WaitAsync和Release方法都是线程安全的,配合互斥锁的保护,整个调整逻辑不存在竞态问题。
  • 如果需要严格保证外部读取ThreadLimit和调整操作的一致性,也可以单独提供读取方法,读取时先获取_modifyLock,再返回数值。

内容的提问来源于stack exchange,提问作者Eduard G

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.10.13 01:12:03