c# - 在 C# 中将 Func 与任务一起使用

Question

我在尝试理解 Func 的确切含义时遇到了一些问题在 C# 中工作，尽管阅读了一些关于它的好博文。

我有以下场景: 我正在构建一个小型计费系统，它使用 Azure 服务总线队列来处理计费。有两个进程可以由用户初始化:

1. 创建一个记事簿以检查之前的交易是否正确
2. 为客户创建实际发票

为此，我制定了一个通用方法来初始化一个需要 bool 的计费任务(包含 N 个计费)。参数来判断它是需要创建的记事本还是实际账单。在此方法中，我正在运行以下检查:

if (isDayBookProcessing)
{
    // Daybook processing code here   
}
else
{
    // Run queue process async
    StartQueueProcess(queueName, billingTaskId, numOfItemsEnqueued);
}

然后我得到了一个通用的“StartQueueProcess”方法，它在它自己的 Task 中运行像这样:

private void StartQueueProcess(string queueName, int billingTaskId, int numOfItemsEnqueued)
{
    Task.Factory.StartNew(() => _factory.AzureFactory.ServiceBus.ProcessBillingQueue(queueName, billingTaskId, numOfItemsEnqueued));
}

如您所见，StartQueueProcess方法运行 ProcessBillingQueue我的方法ServiceBus类，这意味着它不能运行 ProcessDaybookQueue

我最初的想法是只利用 Func<string, int, int, bool>并制作StartQueueProcess方法返回一个 bool 值(因为 Func 需要返回一些东西)使它看起来像这样:

if (isDayBookProcessing)
{
    // Daybook processing code here 
    StartQueueProcess(_factory.AzureFactory.ServiceBus.ProcessDaybookQueue(queueName, billingTaskId, numOfItemsEnqueued));  
}
else
{
    // Run queue process async   
    StartQueueProcess(_factory.AzureFactory.ServiceBus.ProcessBillingQueue(queueName, billingTaskId, numOfItemsEnqueued));
}

private bool StartQueueProcess(Func<string, int, int, bool> processMethod)
{
    Task.Factory.StartNew(() => processMethod);

    return true;
}

但是，这给出了一个错误，告诉我 Argument type 'void' is not assignable to parameter type 'System.Func<string, int, int bool>'

我的 _factory.AzureFactory.ServiceBus.ProcessDaybookQueue(queueName, billingTaskId, numOfItemsEnqueued)返回无效。让它返回 Func<string, int, int, bool>没有错误。但究竟是为什么？难道我不能让它返回我想要的(即 void)吗？

任何人都可以阐明这一点吗？ :-)

Answer 1

您不需要Func，您需要一个Action。 Func 是您的委托(delegate)有返回值的时候。当没有返回值时，Action 是合适的:

private void StartQueueProcess(Action<string, int, int> processMethod)
{
    Task.Factory.StartNew(() => processMethod);
}

请注意，包装async over sync is an anti-pattern .您最好在调用站点使用 Task.Run:

if (isDayBookProcessing)
{
    // Daybook processing code here 
    Task.Run(() => _factory.AzureFactory.ServiceBus.ProcessDaybookQueue(
                           queueName, 
                           billingTaskId, 
                           numOfItemsEnqueued));  
}
else
{
    // Run queue process async   
    Task.Run(() => _factory.AzureFactory.ServiceBus.ProcessBillingQueue(
                           queueName,
                           billingTaskId, 
                           numOfItemsEnqueued));
} 

尽管我看到您正在调用相同的方法，所以我认为不需要 if-else。