使用 TPL ping 网络中的所有计算机

Question

我正在开发一个管理网络中设备的应用程序，在应用程序中的某个点，我必须 ping（实际上它不是 ping，它是 SNMP get）网络中的所有计算机以检查其类型是否为我的受管设备。

我的问题是 ping 网络中的所有计算机非常慢（特别是因为它们中的大多数都不会响应我的消息并且只会超时）并且必须异步完成。

我尝试使用 TLP 通过以下代码执行此操作：

public static void FindDevices(Action<IPAddress> callback)
{
    //Returns a list of all host names with a net view command
    List<string> hosts = FindHosts();

    foreach (string host in hosts)
    {
        Task.Run(() =>
        {
            CheckDevice(host, callback);
        });
    }
}

但是它运行非常慢，当我暂停执行时，我检查了线程窗口，发现它只有一个线程 ping 网络，因此同步运行任务。

当我使用普通线程时，它运行得更快，但任务应该更好，我想知道为什么我的任务没有优化并行性。

**编辑** 评论要求 CheckDevice 上的代码，所以这里是：

    private static void CheckDevice(string host, Action<IPAddress> callback)
    {
        int commlength, miblength, datatype, datalength, datastart;
        string output;
        SNMP conn = new SNMP();


        IPHostEntry ihe;
        try
        {
            ihe = Dns.Resolve(host);
        }
        catch (Exception)
        {
            return;
        }
        // Send sysLocation SNMP request
        byte[] response = conn.get("get", ihe.AddressList[0], "MyDevice", "1.3.6.1.2.1.1.6.0");

        if (response[0] != 0xff)
        {
            // If response, get the community name and MIB lengths
            commlength = Convert.ToInt16(response[6]);
            miblength = Convert.ToInt16(response[23 + commlength]);

            // Extract the MIB data from the SNMP response
            datatype = Convert.ToInt16(response[24 + commlength + miblength]);
            datalength = Convert.ToInt16(response[25 + commlength + miblength]);
            datastart = 26 + commlength + miblength;
            output = Encoding.ASCII.GetString(response, datastart, datalength);
            if (output.StartsWith("MyDevice"))
            {
                callback(ihe.AddressList[0]);
            }
        }
    }

Answer 1

您的问题是您正在迭代 List 的非线程安全项。

如果您将其替换为像ConcurrentBag 这样的线程安全对象，您应该会发现线程将并行运行。

---

我有点困惑，为什么它只运行一个线程，我相信是这行代码：

try
{
    ihe = Dns.Resolve(host);
}
catch (Exception)
{
    return;
}

我认为这是抛出异常并返回；因此你只看到一个线程。这也与您的观察有关，即如果您添加了睡眠，它会正常工作。

请记住，当您传递一个字符串时，您传递的是对内存中字符串的引用，而不是值。无论如何，ConcurrentBag 似乎可以解决您的问题。 This answer might also be relevant