在 foreach 中访问 LINQ Select 中使用的值

Question

给定一个 IP 地址列表：

List<string> ipList = new List<string>(); //example: 192.168.0.1, 192.168.0.2, 192.168.0.3 etc.

我正在尝试以并行方式遍历列表中的每个 IP，然后在屏幕上打印一条有意义的消息：

foreach (PingReply pingReply in ipList.AsParallel().WithDegreeOfParallelism(64).Select(ip => new Ping().Send(ip)))
{
    Console.WriteLine($"Ping status: {pingReply.Status} for the target IP address: {ip}");
}

在这种情况下，我无法访问 ip。我真的很想了解在发送它们时如何访问每个 relative ip？

我已经探索了PingReply 对象，但以PingReply.Address 为例，它包含主机（发件人）IP，因此无法满足此要求。我真的希望 PingReply 对象包含被 ping 的 Ip！

---

更新

根据@haim770 和@MindSwipe 提供的示例，我最终使用了：

foreach (var pingResponseData in ipList.AsParallel().WithDegreeOfParallelism(64).Select(ip => new { ip, pingReply = new Ping().Send(ip) }))
{
    Console.WriteLine($"Ping status: {pingResponseData.pingReply.Status} for the target IP address: {pingResponseData.ip}");
}

---

更新 2

根据@pinkfloydx33 关于使用ValueTuple 的评论，我已按照以下示例完成：

foreach (var (ip, reply) in ipList.AsParallel().WithDegreeOfParallelism(ipList.Count).Select(ip => (ip, new Ping().Send(ip, 150))))
{
    Console.WriteLine($"Ping status: {reply.Status} for the target IP address: {ip}");
}

Answer 1

您目前只选择pingReply，而不是ip 和pingReply，为此您需要选择一个新的anonymous type 并对其进行迭代。像这样：

foreach (var (pingReply, ip) in ipList.AsParallel().WithDegreeOfParallelism(64).Select(ip => (ip, Ping().Send(ip))))
{
    // Here 'i' is an object with the properties 'ip' and 'pingReply'
    Console.WriteLine($"Ping status: {i.pingReply.Status} for the target IP address: {i.ip}");
}

---

编辑：现在刚刚注意到haim770 基本上在their comment 中发布了这个

编辑 2：感谢pinkfloydx33 指出我可以使用tuple deconsturcting

Answer 2

以并行度 = 64 并行调用同步的Ping.Send 效率相当低，因为在并行执行期间阻塞了多达 64 个线程（前提是ThreadPool 有足够的可用线程来满足需求，这是值得怀疑的）。执行 ping 的更有效方法是使用异步 Ping.SendPingAsync 方法。要以不超过 64 个异步操作同时进行的方式调用此方法，您将需要与异步委托一起使用的 Parallel.ForEach 等效项。目前没有这样的内置功能（在 .NET 6 中可能是 be available），但是如果您搜索 ForEachAsync，您可以找到很多自定义实现。例如有一个here。然后你就可以这样做了：

var ipList = new List<string>() {"192.168.0.1", "192.168.0.2", "192.168.0.3"}; // etc

ipList.ForEachAsync(async ip =>
{
    var ping = new Ping();
    var reply = await ping.SendPingAsync(ip);
    Console.WriteLine($"IP '{ip}' ping reply status: {reply.Status}");
}, dop: 64).Wait();

你也可以await完成操作，而不是使用阻塞Wait，前提是你从async方法调用它。