AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 79558419
Accepted
Pragmateek
Pragmateek
Asked: 2025-04-06 23:53:45 +0800 CST2025-04-06 23:53:45 +0800 CST 2025-04-06 23:53:45 +0800 CST

Por que os endpoints da API mínima estão esperando por tarefas?

  • 772

Ao criar uma API mínima básica do ASP.NET Core, fiquei surpreso com o fato de que, se um endpoint retorna um Task, a solicitação não retorna até que o Taskseja concluído:

var builder = WebApplication.CreateBuilder(args);

builder.Services.AddSingleton<ICounterService, CounterService>();

var app = builder.Build();

app.MapGet("/counter/value", (ICounterService counter) => counter.Value);
app.MapGet("/counter/incrementnow", (ICounterService counter) => counter.Increment());
app.MapGet("/counter/incrementlater", (ICounterService counter) => Task.Delay(TimeSpan.FromSeconds(5)).ContinueWith(_ => counter.Increment()));
app.MapGet("/counter/incrementlaternowait", (ICounterService counter) => { Task.Delay(TimeSpan.FromSeconds(5)).ContinueWith(_ => counter.Increment()); return; });

app.Run();

interface ICounterService
{
    int Value { get; }
    void Increment();
}

class CounterService : ICounterService
{
    public int Value { get; private set; }

    public void Increment()
    {
        int previousValue = Value++;
        Console.WriteLine($"Incremented from {previousValue} to {Value}.");
    }
}

Onde esse comportamento está documentado?

Eu esperaria esse comportamento se eu explicitamente awaiteditasse a tarefa em um asyncendpoint.

c#
  • 3 3 respostas
  • 128 Views

3 respostas

  • Voted
  1. Best Answer
    Ivan Petrov
    2025-04-07T00:31:53+08:002025-04-07T00:31:53+08:00

    Não acho que esteja explicitamente documentado. A documentação faz parecer que é permitido retornar apenas o Task(sem menção de que awaitele está usando ing ou que é um tipo especial):

    Os pontos de extremidade mínimos oferecem suporte aos seguintes tipos de valores de retorno:

    1. string- Isso inclui Task<string>e ValueTask<string>.
    2. T( Qualquer outro tipo ) - Isso inclui Task<T>e ValueTask<T>.
    3. IResultbaseado - Isso inclui Task<IResult>e ValueTask<IResult>.

    Assim Taskcomo "qualquer outro tipo T", não um string, não implementando IResulttambém, então ele deve ser retornado como serializado json, e não explicitamente awaited.

    Entretanto , os endpoints (métodos de ação do controlador ou lambdas de APIs mínimas) são convertidos em RequestDelegates:

    public delegate Task RequestDelegate(HttpContext context);
    

    antes de RequestDelegateFactoryserem conectados ao pipeline de middleware, onde você basicamente tem:

    await requestDelegate();
    

    Parte da mágica RequestDelegateFactoryé garantir que o comando acima tambémawait contenha qualquer tipo aguardável, como o que seu método/lambda está retornando. Veja também esta pergunta . awaitTask

    Portanto Task, como um tipo de retorno tem um significado especial - a versão assíncrona dos voidmétodos de retorno síncronos/lambdas. Voltando à documentação acima

    1. T( Qualquer outro tipo ) - Isso inclui Task<T>e ValueTask<T>.

    No nosso caso Tis typeof(void)e Taskis esse contexto é realmente um Task<void>e não seu próprio Ttipo.

    Acredito que essa interpretação seja corroborada pelo reconhecimento da equipe principal do asp.net de um bug na lógica do subpipeline do filtro .NET7+ ( os filtros do manipulador de rotas não manipulam todos os tipos de retorno ), no qual o Taskobjeto era encapsulado como um objeto normal ValueTask<object>e não era aguardado mais acima no middleware normal - o encapsulamento ValueTask<object>era aguardado - então era possível retorná-lo como jsonresposta, em vez awaitingdele:


    Task Method() => Task.CompletedTask;
    app.MapGet("/method", Method).AddFilter((c, n) => n(c));
    
    

    Saída:

    {"result":{},"id":54,"exception":null,"status":5,"isCanceled":false,"isCompleted":true,"isCompletedSuccessfully":true,"creationOptions":0,"asyncState":null,"isFaulted":false}
    

    Descrição do bug:

    Atualmente, os filtros envolvem o delegado do usuário em um método ValueTask<object?>antes de entregar a função à lógica de tratamento de rota normal. Isso causa problemas com métodos que não retornam objetos , como void, Task, Task<T>, etc.

    então eles tiveram que mudar a RequestDelegateFactorylógica para realmente fazer isso awaitno delegado construído, e não depender do awaitpróximo nível superior no pipeline - código-fonte :

    private static ValueTask<object?> ExecuteTaskWithEmptyResult(Task task) {
        static async ValueTask<object?> ExecuteAwaited(Task task) {
            await task;
            return EmptyHttpResult.Instance;
        }
    
        if (task.IsCompletedSuccessfully) {
            return new ValueTask<object?>(EmptyHttpResult.Instance);
        }
    
        return ExecuteAwaited(task);
    }
    

    Se quisermos retornar um Taskque não seja awaited para nós, podemos fazer uso de um lambda que retorna Task<Task>e um filtro.

    app.MapGet("/taskreturn", () => Task.FromResult(Task.Delay(5000)))
    .AddEndpointFilter(async (context, next) =>
    {
        var result = await next(context); // next gives us Task<Task>
        // if we return result here it will be the uncompleted task
        // immediately
        //return result;
    
        if (result is Task task)
        {
            await task; // wait for 5 seconds
            //return task;
            // if we return here it will be the completed task
        }
    
        // or we can return something else
        return "from filter";
    });
    
    
    • 3
  2. MrC aka Shaun Curtis
    2025-04-07T02:19:57+08:002025-04-07T02:19:57+08:00

    Está documentado: basta pesquisar um pouco. Culpe os mecanismos de busca por promoverem lixo em vez de conteúdo real!

    MapGeté um método de extensão com dois padrões definidos em public static class EndpointRouteBuilderExtensions:

    public static IEndpointConventionBuilder MapGet(this IEndpointRouteBuilder endpoints, string pattern, RequestDelegate requestDelegate);
    
    public static IEndpointConventionBuilder MapGet(this IEndpointRouteBuilder endpoints, string pattern, delegate handler);
    
    public delegate Task RequestDelegate(HttpContext context);
    

    E o link do MSDocs:

    https://learn.microsoft.com/en-us/dotnet/api/microsoft.aspnetcore.builder.endpointroutebuilderextensions?view=aspnetcore-9.0

    Fiquei surpreso com o fato de que se um endpoint retorna uma tarefa, a solicitação não retorna até que a tarefa seja concluída

    Você não pode retornar um Task. Se quiser um retorno no primeiro yield, retorne um null, não uma Task, para o endpoint.

    Então você pode reescrever seu código assim, aguardando a conclusão da tarefa:

    app.MapGet("/counter/incrementlater", IncrementLater);
    
    //...
    
    app.Run();
    
    async Task IncrementLater(HttpRequest request, ICounterService counter )
    {
        await Task.Delay(TimeSpan.FromSeconds(5));
        counter.Increment();
    }
    

    ou isto que retornaria no primeiro rendimento, ou seja, Task.Delay):

    app.MapGet("/counter/incrementlater", IncrementLater);
    
    //...
    
    app.Run();
    
    async void IncrementLater(HttpRequest request, ICounterService counter )
    {
        await Task.Delay(TimeSpan.FromSeconds(5));
        counter.Increment();
    }
    
    • 2
  3. poke
    2025-04-07T20:04:24+08:002025-04-07T20:04:24+08:00

    Delegados de endpoint de API mínima se comportam da mesma forma que ações de controlador no MVC clássico. Portanto, se você estiver retornando um, Taskisso significa que seu endpoint/ação é assíncrono e que ainda há trabalho em andamento que precisará ser aguardado pelo framework para descobrir como será a resposta HTTP real.

    Não há nada de especial na API Minimal aqui. Você parece estar confuso porque o delegado do endpoint não usa asynce , awaitmas nenhum dos dois é necessário em ações do controlador. Por exemplo, o seguinte é uma ação de controlador assíncrona perfeitamente adequada:

    public Task<string[]> GetWeatherData()
    {
        return _weatherService.GetWeatherDataAsync();
    }
    

    Semanticamente, isso também é o mesmo que o seguinte, que usa async/await:

    public async Task<string[]> GetWeatherData()
    {
        return await _weatherService.GetWeatherDataAsync();
    }
    

    Mas como _weatherService.GetWeatherDataAsyncjá retorna uma tarefa, você não precisa necessariamente executar a ação asyncnela await, mas pode simplesmente retornar a tarefa diretamente do serviço meteorológico (embora isso tenha alguns efeitos que podem ou não ser desejados).

    Em ambos os casos, a ação retorna um Task<string[]>e é isso que fará o ASP.NET Core aguardar a ação para aguardar a resposta. O asyncapenas dirá ao compilador para fazer sua mágica para que você possa usar await. Mas ele é praticamente invisível (e irrelevante) para o tempo de execução.


    Nos comentários, você mencionou "disparar e esquecer". Se você quiser que um endpoint (API mínima ou ação do controlador) se comporte como "disparar e esquecer" enquanto ainda executa algo em segundo plano, precisará mover essa ação explicitamente para segundo plano, gerando uma nova thread. Isso pode ser tão simples quanto usar Task.Run:

    // I’m using actions here but this would be identical in Minimal API delegates
    public async Task<IActionResult> GetWeatherData()
    {
        // do not await the completion of this task
        _ = Task.Run(async () =>
        {
            await Task.Delay(5000);
            var data = await _weatherService.GetWeatherDataAsync();
            _logger.LogInformation("Received weather data in the background: {Data}", data);
        });
    
        await Task.Delay(1000);
        return Ok();
    }
    

    Ou para usar seu exemplo:

    app.MapGet("/counter/incrementlater", (ICounterService counter) =>
    {
        // do not await the completion of this task
        _ = Task.Run(async () =>
        {
            await Task.Delay(TimeSpan.FromSeconds(5));
            counter.Increment();
        }
    });
    

    Observe que, neste caso, o uso counterfuncionará, pois está registrado como um serviço singleton. Para outros escopos de serviço, especialmente um serviço com escopo (como um contexto de banco de dados EF), isso não funcionará e você precisará criar seu próprio escopo de serviço dentro da sua tarefa em segundo plano para evitar que o serviço com escopo seja descartado quando o endpoint/ação for concluído (o que ocorre antes da sua tarefa em segundo plano).

    • 2

relate perguntas

  • Polly DecorrelatedJitterBackoffV2 - como calcular o tempo máximo necessário para concluir todas as novas tentativas?

  • Wpf. Role o DataGrid dentro do ScrollViewer

  • A pontuação que ganhei na página do jogo com .NET MAUI MVVM não é visível em outras páginas. Como posso manter os dados de pontuação no dispositivo local

  • Use a hierarquia TreeView com HierarchicalDataTemplate de dentro de um DataTemplate

  • Como posso melhorar essa interface de validação no .NET?

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Reformatar números, inserindo separadores em posições fixas

    • 6 respostas
  • Marko Smith

    Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não?

    • 2 respostas
  • Marko Smith

    Problema com extensão desinstalada automaticamente do VScode (tema Material)

    • 2 respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Martin Hope
    Fantastic Mr Fox Somente o tipo copiável não é aceito na implementação std::vector do MSVC 2025-04-23 06:40:49 +0800 CST
  • Martin Hope
    Howard Hinnant Encontre o próximo dia da semana usando o cronógrafo 2025-04-21 08:30:25 +0800 CST
  • Martin Hope
    Fedor O inicializador de membro do construtor pode incluir a inicialização de outro membro? 2025-04-15 01:01:44 +0800 CST
  • Martin Hope
    Petr Filipský Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não? 2025-03-23 21:39:40 +0800 CST
  • Martin Hope
    Catskul O C++20 mudou para permitir a conversão de `type(&)[N]` de matriz de limites conhecidos para `type(&)[]` de matriz de limites desconhecidos? 2025-03-04 06:57:53 +0800 CST
  • Martin Hope
    Stefan Pochmann Como/por que {2,3,10} e {x,3,10} com x=2 são ordenados de forma diferente? 2025-01-13 23:24:07 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve