2

我们在网络角色中有一些工作线程。它是在OnStart方法中创建的

Task.Factory.StartNew(() => DoWorkAsync(), TaskCreationOptions.LongRunning);

然后该DoWorkAsync方法将继续轮询队列并做一些耗时的工作。实际工作需要几分钟，因为它提交查询作业并等待结果返回。这些功能在async模式中。实现顶级DoWorkAsync方法的正确方法是什么？如果我执行以下操作，那么这里有点阻塞，并且只PollingQueueAndWorkAsync()调用了一个。

public async void DoWorkAsync()
{
  while (_continue)
  {
    await PollingQueueAndWorkAsync();
  }
}

还是以下？它看起来不正确，因为它一直在不同的线程中运行该方法。

public async void DoWorkAsync()
{
  while (_continue)
  {
    Task.Run(() => PollingQueueAndWorkAsync());
  }
}

我正在尝试将代码重构为“一直异步”。但它应该如何以顶级工作者方法结束？

[更新]

在尝试更多之后，这就是我所拥有的：

public async void DoWorkAsync()
{
  while (_continue)
  {
    Task.Run(async () => await PollingQueueAndWorkAsync());
  }
}

这种行为是我想要的，因为新消息不断添加到队列中，这个循环可以处理队列中的消息。然而，在运行一段时间后，它会抛出我们的内存异常。是因为它创造了太多的延续吗？所以我应该使用 SemaphoreSlim 来限制任务数量？

4

2 回答 2

2

我通常不鼓励在 ASP.NET 中执行与请求无关的代码。但是，如果它是作为独立工作者仔细编写的（听起来确实如此），那么您可以使用我博客中的BackgroundTaskManager类型。

BackgroundTaskManager理解同步和异步任务，并且这些任务在 ASP.NET 运行时中注册，以最大限度地减少循环意外终止它们的机会。此外，该类型公开了一个CancellationToken调用BackgroundTaskManager.Shutdown，您PollingQueueAndWorkAsync可以使用它来检测它何时应该干净地退出。

于 2013-10-12T04:16:40.147 回答
0

您应该像这样创建轮询线程：

public async void DoWorkAsync()
{
    await Task.Run(() => PollingQueueAndWorkAsync());
}

然后你应该在线程本身中检查'_continue'，以便在工作被取消时它们可以干净地退出。

于 2013-10-12T01:50:06.043 回答