在.Net Core 3.1应用程序中的ExecuteAsync中等待之后，后台服务会阻塞

如何解决在.Net Core 3.1应用程序中的ExecuteAsync中等待之后，后台服务会阻塞

我需要一个服务，该服务不断轮询来自Kafka主题的消息，将该消息提供给处理任务，获取该任务结束的结果，将其推送到另一个Kafka主题。我使用.Net Core 3.1中的BackgroundService作为基本基础结构，同时编写了ConsumerProducer类，该类封装了具有以下公共方法的Kafka内容：

    public async Task ReceiveAndReply(ReplyCallback replyCallback)
    {
        try
        {
            var msg = consumer.Pull();

            var reply = await replyCallback(msg);

            producer.PushAsync((message)reply);
        }
        catch (Exception e)
        {
            throw new Exception(e.InnerException.Message);
        };

    }

BackgroundService派生类如下：

public class Worker : BackgroundService{

    // initialization stuff....

   protected ReplyCallback processDelegate = new ReplyCallback(ProcessQuery);

    protected static Task<message> ProcessQuery(message source)
    {
        return new Task<message>>(() => 
        {
            
            try
            {
                var messagePayload= ProcesspulledMessage(source);

                var replyMessage = new Message(messagePayload);

                return replyMessage;
            }
            catch(Exception ex)
            {
                Console.WriteLine(ex.Message);
                return null;
            }
        });
    }
    

    protected override async Task ExecuteAsync(CancellationToken stoppingToken)
    {

        while (!stoppingToken.IsCancellationRequested)
        {
            try
            {
                await connector.ReceiveAndReply(processDelegate);
            }
            catch (Exception ex)
            {
                throw new Exception(ex.InnerException.Message);
            }
        }
    }


}

该代码已简化，但它描述了这种情况。在运行时，我可以使用主题中的消息，但是当要等待ProcessQuery中的任务时，执行将退出，应用程序将继续运行，但是从未执行过等待的任务。 也许我做的是完全错误的事情，我不是复杂异步工作的专家，所以任何技巧都将受到欢迎。 谢谢

解决方法

您要返回未启动的任务。

Task constructor的文档指出：

实例化Task对象并启动任务的最常见方法是调用静态Task.Run(Action)或TaskFactory.StartNew（Action）方法，而不是调用此构造方法。