长时间停顿的并行任务

Question

我有一个类似的功能

   private void DoSomethingToFeed(IFeed feed)
   {
      feed.SendData(); // Send data to remote server
      Thread.Sleep(1000 * 60 * 5); // Sleep 5 minutes
      feed.GetResults(); // Get data from remote server after it's processed it
   }

我想并行化这个，因为我有很多相互独立的提要。基于this answer，将Thread.Sleep() 留在其中并不是一个好主意。我还想在所有线程都启动后等待，直到它们都有机会获得结果。

处理这种情况的最佳方法是什么？

编辑，因为我不小心把它漏掉了：我本来考虑把这个函数称为Parallel.ForEach(feeds, DoSomethingToFeed)，但是当我找到答案时我想知道是否有更好的方法来处理睡眠我链接到了。

Answer 1

我认为您应该看看 .NET 中的 Task 类。这是在更底层线程/线程池管理之上的一个很好的抽象。

为了等待所有任务完成，您可以使用Task.WaitAll。

Tasks 的用法示例如下：

IFeed feedOne = new SomeFeed();
IFeed feedTwo = new SomeFeed();

var t1 = Task.Factory.StartNew(() => { feedOne.SendData(); });

var t2 = Task.Factory.StartNew(() => { feedTwo.SendData(); });

// Waits for all provided tasks to finish execution
Task.WaitAll(t1, t2);

但是，另一种解决方案是使用Parallel.ForEach，它会为您处理所有Task 创建并执行适当的任务批处理。 here 对这两种方法进行了很好的比较 - 其中指出：

Parallel.ForEach 在内部使用分区器将您的集合分配到工作项中。它不会对每个项目执行一项任务，而是将其批处理以降低所涉及的开销。

Answer 2

检查 WaitHandle 等待任务。

Answer 3

除非你有很多线程，否则你可以保持简单。创建所有线程。您将获得一些线程创建开销，但由于线程基本上一直处于休眠状态，您不会获得太多的上下文切换。

它比任何其他解决方案都更容易编码（除非您使用的是 C# 5）。所以从这个开始，只有当你真正看到性能问题时才改进它。

Answer 4

private void DoSomethingToFeed(IFeed feed)
{
    Task.Factory.StartNew(() => feed.SendData())
        .ContinueWith(_ => Delay(1000 * 60 * 5)
                          .ContinueWith(__ => feed.GetResults())
                     );
}

//http://stevenhollidge.blogspot.com/2012/06/async-taskdelay.html
Task Delay(int milliseconds)      
{
    var tcs = new TaskCompletionSource<object>();
    new System.Threading.Timer(_ => tcs.SetResult(null)).Change(milliseconds, -1);
    return tcs.Task;
}