等待所有线程结束

Question

我有一些代码想用于网络上的设备发现。 它只是简单地 ping 所述网络上的任何 IP 地址，如果得到答案，则将地址添加到列表中。

代码如下：

static void Main(string[] args){
    //do stuff to get subnetmask and local address
    //succession of for loop to increment ip address
    {
        PingAsync(ip_address);
    }

    //here I display the list of addresses that answered the ping
    //first Readline() is to manually wait for threads to end so the list isn't empty
    Console.Readline()
    Console.WriteLine("List of all devices found :\n");
    ipList.ForEach(delegate (string str)
        {
            Console.WriteLine($"\t=> {str}");
        });
    Console.ReadLine();
}

private static void PingAsync(IPAddress address)
{
    AutoResetEvent waiter = new AutoResetEvent(false);

    Ping pingSender = new Ping();
    //items are added to ipList in PingCompletedCallback()
    pingSender.PingCompleted += new PingCompletedEventHandler(PingCompletedCallback);

    string data = "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa";
    byte[] buffer = Encoding.ASCII.GetBytes(data);

    int timeout = 1200;

    PingOptions options = new PingOptions(64, true);

    pingSender.SendAsync(address, timeout, buffer, options, waiter);
}

在 PingCompletedCallback 方法中，我将项目添加到将显示在主列表中的列表

private static void PingCompletedCallback(object sender, PingCompletedEventArgs e)
{
    Program prog = new Program();

    if (e.Cancelled)
    {
        Console.WriteLine("Ping failed !");
        Console.WriteLine(e.Error.ToString());
        ((AutoResetEvent)e.UserState).Set();
    }

    if(e.Error != null)
    {
        Console.WriteLine("Ping failed !");
        Console.WriteLine(e.Error.ToString());

        ((AutoResetEvent)e.UserState).Set();
    }

    PingReply reply = e.Reply;

    if(reply.Status.ToString().Equals("Success", StringComparison.OrdinalIgnoreCase))
    {
    //If the ping succeeds add the address to a list
        ipList.Add(reply.Address.ToString());
    }

    ((AutoResetEvent)e.UserState).Set();
}

代码在发现设备方面运行良好，唯一的问题是地址列表。如果我不手动等待所有线程结束，它将显示为空。

根据这些帖子(1)(2) 和其他一些帖子，使用 Thread.join 或 Task.Waitall 是要走的路。但是，与他们不同的是，我不是自己创建线程，而是让 SendAsync() 创建自己的线程。

另外，我无法更改 PingAsync() 以使其等待 SendAsync()，因为它返回 void。

我想知道你会在打印/使用 ipList 之前等待线程结束。

Answer 1

这段代码大部分可以替换为Ping.SendPingAsync：

static async Task Main(string[] args)
{

   using var pingSender = new Ping();
   var options = new PingOptions(64, true);
   var reply=await pingSender.SendPingAsync(address,1200,options)
   if(reply.Status == IPStatus.Success)
   {
      ...
   }
}

并发请求 - 每个请求一个发件人

SendPingAsync 不能多次调用以从单个发件人发送多个请求。这样做会引发 InvalidOperationException。

一种解决方案是为每个呼叫创建和使用单独的发件人：

async Task<Reply> PingAsync(IPAddress address)
{
    using var pingSender = new Ping();
   var options = new PingOptions(64, true);
   var reply=await pingSender.SendPingAsync(address,1200,options)
}

结合 LINQ，可以同时启动多个 ping 并收集结果：

var addresses=new List<IPAddress>();
...
//Create the tasks with LINQ
var tasks=addresses.Select(address=>PingAsync(address))
                   .ToArray();
//And wait for all of them to complete
var replies=await Task.WhenAll(tasks);

//Get the successful pings:
var successes=replies.Where(reply=>reply.Status==IPStatus.Success)
                     .Select(reply=>reply.Address.ToString())
                     .ToArray();

第一个 LINQ 查询将为每个地址调用 PingAsync，并返回每个调用返回的 Task<Reply> 对象：

var tasks=addresses.Select(address=>PingAsync(address))
                   .ToArray();

查询实际上是在调用ToArray() 时计算的。所有 ping 请求将同时开始。

下一个调用等待他们全部完成：

var replies=await Task.WhenAll(tasks);

最后，最后一个 LINQ 查询检索成功 ping 的 IP：

var successes=replies.Where(reply=>reply.Status==IPStatus.Success)
                     .Select(reply=>reply.Address.ToString())
                     .ToArray();