Durable Entities出现Buffered状态的原因排查及问题咨询

核心问题 #

你写的SetTaskLanguages方法里用Task.Run包装了同步的AddRange操作，这是Durable Entity的典型错误用法：

• Durable Entity的执行是单线程上下文，所有状态变更必须在这个上下文内完成，不能通过Task.Run把逻辑丢到后台线程执行
• 用Task.Run会让状态更新脱离Entity的调度控制，导致框架无法感知操作完成，信号调用一直处于缓冲状态，后续所有对该实体的调用都会被阻塞

修复代码 #

把SetTaskLanguages方法改成同步实现（或者去掉多余的Task.Run）：

public class OrchestrationData : IOrchestrationData
{
    [FunctionName(nameof(OrchestrationData))]
    public static Task Run([EntityTrigger] IDurableEntityContext context)
        => context.DispatchAsync<OrchestrationData>();

    [JsonProperty("taskLanguages")] 
    public List<MyLang> TaskLanguages { get; set; } = new List<MyLang>();

    // 改成同步方法，框架会自动适配调度逻辑
    public void SetTaskLanguages(MyLangCol languages)
    {
        TaskLanguages.AddRange(languages.MyLangs);
    }

    // 也可以保留Task返回，但不要用Task.Run
    // public Task SetTaskLanguages(MyLangCol languages)
    // {
    //     TaskLanguages.AddRange(languages.MyLangs);
    //     return Task.CompletedTask;
    // }
}

补充说明 #

Durable Entity的方法支持同步或异步签名，但绝对不能用Task.Run包装同步逻辑——这会破坏Entity的单线程执行模型，导致状态无法正确持久化、操作被缓冲阻塞等问题。当你调用实体的信号方法（SetTaskLanguages在这里是信号调用），框架需要确认操作在Entity上下文内完成，才能继续处理后续的调用。

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