c# - Parallel.ForEach 使用 Thread.Sleep 等效

Question

情况是这样的:我需要调用一个开始搜索的网站。此搜索持续了未知的时间，我知道搜索是否完成的唯一方法是定期查询网站以查看其某处是否有“下载数据”链接(它在 javascript 上使用了一些奇怪的 ajax 调用计时器检查后端和更新页面，我想)。

技巧如下:我需要搜索数百个项目，一次搜索一个。所以我有一些代码看起来有点像这样:

var items = getItems();
Parallel.ForEach(items, item =>
{
   startSearch(item);
   var finished = isSearchFinished(item);
   while(finished == false)
   {
      finished = isSearchFinished(item); //<--- How do I delay this action 30 Secs?
   }
   downloadData(item);
}

现在，显然这不是真正的代码，因为可能有一些事情导致 isSearchFinished 始终为 false。

撇开明显的无限循环危险不谈，我如何正确地防止 isSearchFinished() 一遍又一遍地调用，而是每隔 30 秒或 1 分钟调用一次？

我知道 Thread.Sleep() 不是正确的解决方案，我认为该解决方案可能通过使用 Threading.Timer() 来完成，但我不是很熟悉，而且线程选项太多，我只是不确定该使用哪个。

Answer 1

使用任务和 async/await 很容易实现，正如@KevinS 在评论中指出的那样:

async Task<ItemData> ProcessItemAsync(Item item)
{
    while (true)
    {
        if (await isSearchFinishedAsync(item))
            break;
        await Task.Delay(30 * 1000);
    }
    return await downloadDataAsync(item);
}

// ...

var items = getItems();
var tasks = items.Select(i => ProcessItemAsync(i)).ToArray();
await Task.WhenAll(tasks);
var data = tasks.Select(t = > t.Result);

这样，您就不会阻塞 ThreadPool线程对于主要是一堆 I/O 绑定(bind)的网络操作来说是徒劳的。如果您不熟悉 async/await , async-await 标签 wiki 可能是一个很好的起点。

我假设您可以转换您的同步方法 isSearchFinished和 downloadData使用类似 HttpClient 的异步版本用于非阻塞 HTTP 请求并返回 Task<> .如果你做不到，你仍然可以简单地用 Task.Run 包裹它们。 , 作为 await Task.Run(() => isSearchFinished(item))和 await Task.Run(() => downloadData(item)) .通常不推荐这样做，但由于您有数百个项目，与 Parallel.ForEach 相比，它仍然会为您提供更好的并发级别。在这种情况下，由于异步 Task.Delay，您不会阻塞池线程 30 秒.