Parallel.ForEach 花费的时间比预期的要长

本文关键字：时间 ForEach Parallel | 更新日期: 2023-09-27 18:32:20

这里是关于这个问题的代码：

while (true)
{
    Console.WriteLine("start " + DateTime.Now);
    ParallelOptions options = new ParallelOptions();
    options.MaxDegreeOfParallelism = -1;                
    Parallel.ForEach(hosts, item =>
    {
        using (Ping ping = new Ping())
        {
            PingReply pingReply = ping.Send(item.Value, 2000);  // timeout is 2 secs
            App.dict[item.Key].lastConnectTry = new KeyValuePair<bool, DateTime>((pingReply.Status == IPStatus.Success), DateTime.Now);
        }
    });        
    Console.WriteLine("end " + DateTime.Now);
    Thread.Sleep(15000);
}

但是，然后我运行该应用程序，它给出的结果略有不同：

start 27.04.2012 10:12:32
end 27.04.2012 10:12:42
// it took 10 seconds
start 27.04.2012 10:12:57
end 27.04.2012 10:13:02
// this took 5 secs
start 27.04.2012 10:13:17
end 27.04.2012 10:13:22
//   5 secs
start 27.04.2012 10:13:37
end 27.04.2012 10:13:42
// 5 secs
start 27.04.2012 10:13:57
end 27.04.2012 10:14:01
start 27.04.2012 10:14:16
end 27.04.2012 10:14:19
start 27.04.2012 10:14:34
end 27.04.2012 10:14:36
start 27.04.2012 10:14:51
end 27.04.2012 10:14:54
start 27.04.2012 10:15:09
end 27.04.2012 10:15:11
start 27.04.2012 10:15:26
end 27.04.2012 10:15:29
start 27.04.2012 10:15:44
end 27.04.2012 10:15:46
start 27.04.2012 10:16:01
end 27.04.2012 10:16:06
start 27.04.2012 10:16:21
end 27.04.2012 10:16:24
start 27.04.2012 10:16:39
end 27.04.2012 10:16:41
start 27.04.2012 10:16:56
end 27.04.2012 10:16:59
start 27.04.2012 10:17:14
end 27.04.2012 10:17:16

似乎需要一些时间来引导线程，创建它们，然后并行执行时间将正确安排。

所以问题是为什么处理所有处理需要 2 秒以上，我如何通过在处理之前引导线程来避免它？

更新：

此循环放置在单独的后台线程中。

Parallel.ForEach 花费的时间比预期的要长

是的，线程池需要根据负载增加线程数（与 Parallel.ForEach 无关）。

检查 Parallel.ForEach 不会启动新线程和 Parallel.Foreach 生成太多线程以获得某些背景。

您实际上并没有传递并行选项，请参阅此处：

ParallelOptions options = new ParallelOptions();
options.MaxDegreeOfParallelism = -1;                
Parallel.ForEach(hosts, options, item => // note options passed through here
      // etc

如果这还不够，您可以增加线程池：

System.Threading.ThreadPool.SetMinThreads System.Threading.ThreadPool.SetMaxThreads

但请注意，除非你知道你会得到改进，否则我不会碰这个。由于您正在任务代码中执行Ping，因此这可能是每次运行之间增加可变性的原因。

相关文章：