Início / coding / Perguntas / 77121950
Accepted
wforl
Asked: 2023-09-17 21:11:27 +0800 CST

Comportamento da tarefa de longa execução

  • 772

Eu tenho uma classe que contém um arquivo BlockingCollection<Task>usado para enfileirar uma série de tarefas para serem executadas em ordem (FIFO).

A fila em si é iniciada em uma tarefa separada de longa execução.

public class TaskQueue
{
    private readonly BlockingCollection<Task> _queue = new BlockingCollection<Task>();

    public TaskQueue()
    {
        Task.Factory.StartNew(() =>
        {
            ProcessQueue();
        }, TaskCreationOptions.LongRunning);
    }

    private async Task ProcessQueue()
    {
        foreach (var task in _queue.GetConsumingEnumerable())
            await task;
    }
    ...
}

Quando o aplicativo é iniciado, crio muitas instâncias, TaskQueuepois preciso de filas diferentes para diferentes componentes do aplicativo.

O problema que estou vendo é que, embora ProcessQueue()seja iniciado em uma tarefa LongRunning .NET Long Running Task, após a primeira espera da tarefa, ela retorna, ou .NET ThreadPool Workerseja, não é mais uma tarefa de longa execução.

Isso resulta em todas as instâncias TaskQueue.ProcessQueueterminando .NET ThreadPool Workers(após a primeira espera), o que faz com que o aplicativo fique muito lento para iniciar novas tarefas, pois atingiu o número máximo de execuções simultâneas .NET ThreadPool Workers(acredito que isso esteja definido como o número de núcleos que a máquina possui, no meu caso 8), após os quais ela só criará novos .NET ThreadPool Workersa cada segundo ou mais.

Então minhas perguntas são:

  1. Existe uma maneira de retornar a uma tarefa de longa duração?
  2. Ou devo apenas substituir Task.Factory.StartNewpor um novo Thread? que acredito que resolverá o problema, mas não tenho certeza se existe uma maneira melhor.
c#

1 respostas

  1. Best Answer

    Existe uma maneira de retornar a uma tarefa de longa duração?

    Sim, em primeiro lugar, não abandonando a tarefa de longa duração. Você pode alterar a assinatura do ProcessQueueretorno voidem vez de Taskassim:

    private void ProcessQueue()
{
    foreach (var task in _queue.GetConsumingEnumerable())
        task.GetAwaiter().GetResult();
}

    Dessa forma, a LongRunningtarefa alternará entre esperar para consumir uma tarefa e esperar que a tarefa consumida seja concluída. O mesmo thread fará toda a espera.

    Aliás, tanto a asyncversão original do ProcessQueue, quanto a voidversão sugerida aqui, não estão fazendo nada de construtivo. Eles não estão processando nada, estão apenas esperando. Presumo que você omitiu a parte "processo" do método, para manter o exemplo simples. Caso contrário, ProcessQueueseria apenas um exercício de futilidade.

    • 0

relate perguntas