访问字典不存在的键为何导致程序无限挂起？

正常行为预期 #

使用System.Collections.Generic.Dictionary的索引器访问不存在的键时，会立即抛出KeyNotFoundException，这个异常是同步触发的，发生在await语句执行之前。此时Execute方法返回的Task会直接进入Faulted状态，而非挂起。

无限挂起的核心原因 #

你遇到的静默挂起、后续回调无法处理的情况，本质是异常被调用上下文吞入，导致调度/回调机制卡住，结合你的复现场景，具体触发逻辑如下：

1. async void回调的异常吞入：如果Execute方法是作为async void类型的回调触发（比如绑定到System.Timers.Timer的Elapsed事件、或仅接受无返回值委托的调度器），异步方法中抛出的同步异常会被.NET的AsyncVoidMethodBuilder捕获，不会直接冒泡到调用者。若未订阅AppDomain.UnhandledException等全局异常事件，异常会被静默吞掉。
2. 调度器的阻塞逻辑：如果触发Execute的调度器（自定义任务队列、定时组件等）遇到未处理异常时，没有正确跳过失败任务，而是持续重试或卡住当前执行流程，就会导致后续回调无法被处理，表现为程序"无限挂起"。

验证与修复方案 #

验证步骤 #

在Execute方法中添加日志和异常捕获，确认异常是否真的被抛出：

public async Task Execute(FutureEvent futureEvent)
{
    try
    {
        var payLoad = JsonSerializer.Deserialize<UpgradeTask>(futureEvent.Message);
        _logger.LogInformation("待处理UpgradeId: {Id}", payLoad.UpgradeId);
        await _messageMap[payLoad.UpgradeId].Invoke(payLoad);
    }
    catch (Exception ex)
    {
        _logger.LogError(ex, "执行任务时出错");
        throw;
    }
}

修复方案 #

1. 避免async void回调：改用返回Task的委托，确保调用者正确await并处理异常：

   // 示例：Timer回调改用async Task包装
   _timer = new Timer(async state => 
   {
       try
       {
           await Execute(GetFutureEvent());
       }
       catch (Exception ex)
       {
           _logger.LogError(ex, "定时任务执行失败");
       }
   }, null, TimeSpan.Zero, TimeSpan.FromSeconds(5));
   

2. 预先检查字典键：使用TryGetValue替代索引器访问，避免抛出异常：

   public async Task Execute(FutureEvent futureEvent)
   {
       var payLoad = JsonSerializer.Deserialize<UpgradeTask>(futureEvent.Message);
       if (_messageMap.TryGetValue(payLoad.UpgradeId, out var upgradeFunc))
       {
           await upgradeFunc.Invoke(payLoad);
       }
       else
       {
           _logger.LogWarning("未找到UpgradeId: {Id}对应的处理函数", payLoad.UpgradeId);
           // 可选择抛出业务异常或直接跳过
           // throw new InvalidOperationException($"UpgradeId {payLoad.UpgradeId} 无对应处理逻辑");
       }
   }
   

3. 确保调度器异常隔离：在调度器的任务执行逻辑中添加异常捕获，保证单个任务失败不影响后续任务：

   // 自定义任务队列消费逻辑示例
   while (!_stoppingToken.IsCancellationRequested)
   {
       var event = await _eventQueue.DequeueAsync(_stoppingToken);
       try
       {
           await Execute(event);
       }
       catch (Exception ex)
       {
           _logger.LogError(ex, "处理事件失败，继续执行后续任务");
       }
   }
   

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