单一任务与列表 在C＃中

Question

我正在用C＃创建一个简单的端口扫描器，它应该扫描给定IP范围的开放端口。我在代码的大部分内容中使用async/await和Task，如下所示：

internal class PortScanner
{
    private IPAddress host;
    private int startPort;
    private int endPort;

    private const int PORT_MIN_VALUE = 1;
    private const int PORT_MAX_VALUE = 65535;

    public PortScanner(IPAddress host, int portStart, int portStop)
    {
        this.host = host;
        this.startPort = portStart;
        this.endPort = portStop;
    }

    public PortScanner(IPAddress host)
        : this(host, PORT_MIN_VALUE, PORT_MIN_VALUE)
    {
    }

    private async Task<bool> IsPortOpen(int port)
    {
        Socket socket = null;

        try
        {
            // make a TCP based socket
            socket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

            // connect
            await Task.Run(() => socket.Connect(this.host, port));

            return true;
        }
        catch (SocketException ex)
        {
            if (ex.SocketErrorCode == SocketError.ConnectionRefused)
            {
                return false;
            }
        }
        finally
        {
            if (socket?.Connected ?? false)
            {
                socket?.Disconnect(false);
            }
            socket?.Close();
        }

        return false;
    }

    private async Task CheckPort(int port)
    {
        if (await IsPortOpen(port))
        {
            Console.WriteLine("Host: {0} - Port: {1} is open.", this.host.ToString(), port.ToString());
        }
    }

    public async Task Scan()
    {
        Console.WriteLine("Scanning for {0}", this.host);
        for (int port = this.startPort; port <= this.endPort; port++)
        {
            await CheckPort(port);
        }
    }
}

现在，重点是，如果在Main函数中，我使用单个Task像这样：

try
{
    PortScanner ps = new PortScanner(ipsInRange.Begin, 15, 25);
    var task = ps.Scan();
    task.Wait();
}
catch (Exception ex)
{
    Console.WriteLine(ex);
}

它工作得很好，从某种意义上说，我得到了一个输出（并且需要几秒钟才能完成）：

Scanning for 192.168.1.1
Host: 192.168.1.1 - Port: 21 is open.
Host: 192.168.1.1 - Port: 23 is open.

但是，当我尝试使用List<Task>时，例如：

foreach (var set in setOfIPs)
{
    List<Task> scanTasks = new List<Task>(set.Count());

    foreach (var ip in set)
    {
        scanTasks.Add(Task.Factory.StartNew(async () =>
        {
            PortScanner ps = new PortScanner(ip, 15, 25);
            await ps.Scan();
        }));
    }

    Task.WaitAll(scanTasks.ToArray());
}

我得到的输出就是这个（程序也在1秒内完成）：

Scanning for 192.168.1.3
Scanning for 192.168.1.2
Scanning for 192.168.1.1
Scanning for 192.168.1.4
Scanning for 192.168.1.5

因此，它似乎基本上不会单独扫描它们，因为它不会打印任何打开的端口。任何想法可能是什么问题，如何在Task内调用多个List<Task>？

Answer 1

这是Task.Factory.StartNew的经典陷阱。该方法返回一个Task<T>，其中T是回调的返回类型。您的lambda是异步的，因此返回一个Task。放在一起，你最终得到一个Task<Task>，你在等待外部任务，而你应该等待内部任务。

两种解决方案

1. 推荐的：使用Task.Run而不是Task.Factory.StartNew。这是一般性建议，你不应该使用Task.Factory.StartNew，除非你知道它是正确的解决方案。 Task.Run避免了许多陷阱，例如你遇到的陷阱。

   scanTasks.Add(Task.Run(async () =>
   {
       PortScanner ps = new PortScanner(ip, 15, 25);
       await ps.Scan();
   }));

2. 如果你有合理的理由使用Task.Factory.StartNew，那么你可以在任务上使用.Unwrap()方法，以便能够在内部等待：

   scanTasks.Add(Task.Factory.StartNew(async () =>
   {
       PortScanner ps = new PortScanner(ip, 15, 25);
       await ps.Scan();
   }).Unwrap());