\ApeVolo.Common\Caches\Redis\Service\MessageQueue\InitCore.cs

[huster-songtao]

await Task.Run(async () =>
                                    {
                                        if (parameterInfos.Length == 0)
                                        {
                                            consumerExecutorDescriptor.MethodInfo.Invoke(obj, null);
                                        }
                                        else
                                        {
                                            object[] parameters = { res };
                                            consumerExecutorDescriptor.MethodInfo.Invoke(obj, parameters);
                                        }
                                    });

这里的async需要去掉

[huster-songtao]

//线程
            tasks.Add(Task.Run(async () =>
            {
                using (var scope = serviceProvider.GetRequiredService<IServiceScopeFactory>().CreateScope())
                {

这里的async需要去掉

可以去掉{}，改成 using var scope = serviceProvider.GetRequiredService<IServiceScopeFactory>().CreateScope();

await Task.Run(async () =>
{
    if (parameterInfos.Length == 0)
    {
        consumerExecutorDescriptor.MethodInfo.Invoke(obj, null);
    }
    else
    {
        object[] parameters = { res };
        consumerExecutorDescriptor.MethodInfo.Invoke(obj, parameters);
    }
});

这里的async 可以去掉