.Net 和 Mono 中的 C# Task.WaitAll()

标签 c# linux multithreading dns mono

为什么这段代码在 Windows 和 Linux(使用 Mono)上表现不同?

static void Main(string[] args)
{
    Stopwatch stopwatch = Stopwatch.StartNew();
    Task[] tasks = new Task[1];

    tasks[0] = Task.Run(() =>
    {
        IPHostEntry iphe = Dns.GetHostEntry("8.8.8.8.dnsrbl.org");
    });
    Task.WaitAll(tasks, 2000);
    Console.WriteLine("Done in " + stopwatch.ElapsedMilliseconds + " ms");
}

8.8.8.8.dnsrbl.ru 是一个最终会超时的查询示例。我相信没有工作的 DNS 服务器(或者它的防火墙阻止了我)。

无论如何,关键不是从 DNS 服务器获得结果,关键是 Task.WaitAll() 在等待包含调用 的任务时在 Windows 和 Mono 上的行为Dns.GetHostEntry().

在 Windows 上,当查询在超时期限 (2s) 内未返回任何结果时,程序运行大约需要 2 秒。也就是说,带有超时的 Task.WaitAll 似乎可以工作。在使用 Mono 的 Linux 上运行此程序需要 2 秒才能获得输出,但程序在任务退出之前不会终止。这是为什么?

无论我是否使用带超时的 Time.WaitAll,我似乎都获得了相同的执行时间。

线索在 Dns.GetHostEntry() 中,因为如果我使用 Thread.Sleep() 启动任务,Task.WaitAll() 会按预期工作 模拟长时间运行的任务。 这按预期工作:

tasks[0] = Task.Run(() => Thread.Sleep(10000));

有没有办法强制 Task.WaitAll(Task[] tasks, int millisecondsTimeout) 在 Mono 中运行时实际超时?

编辑:Task.WaitAll() 实际上会在超时期限后返回,但在 Mono 中运行时程序不会终止(直到 Dns.GetHostEntry 超时)。

而且它不是编译器。无论我使用 Visual Studio 还是使用 Mono C# 编译器进行编译,我都会得到相同的结果。

最佳答案

我会回答我自己的问题,尽管应该归功于引导我走上正确轨道的 Evk(感谢伙伴!)

至少可以说这个问题的主题很糟糕。该问题与 Task.WaitAll 无关,而是与 Dns.GetHostEntry 的 Mono 实现有关。正如 Evk 在评论中所说:

That means (most likely) that Dns.GetHostEntry on linux starts new non-background thread. Program cannot complete until all non-background threads are finished.

GetHostEntry() 方法位于源文件 Dns.cs 中,当使用字符串调用时,它会调用 GetHostByName,然后调用 GetHostByName_internal 这是一个位于 w32socket.c 中的外部 C 函数。最后 mono_get_address_info(在 networking-posix.c 中)被调用,我们进入 libc 函数 getaddrinfo。呸!

我看不到任何新的非后台线程正在启​​动,但我发现了这个:

MONO_ENTER_GC_SAFE;
ret = getaddrinfo (hostname, service_name, &hints, &info);
MONO_EXIT_GC_SAFE;

MONO_ENTER_GC_SAFEMONO_EXIT_GC_SAFE 是在 mono-threads-api.h 中定义的宏

#define MONO_ENTER_GC_SAFE  \
    do {    \
        gpointer __gc_safe_dummy;   \
        gpointer __gc_safe_cookie = mono_threads_enter_gc_safe_region (&__gc_safe_dummy)

#define MONO_EXIT_GC_SAFE   \
        mono_threads_exit_gc_safe_region (__gc_safe_cookie, &__gc_safe_dummy);  \
    } while (0)

我没有进一步挖掘,但我相信 Evk 是对的。

所以,我的问题的答案是:Dns.GetHostEntry() 无法在 Mono 中终止或取消。调用此方法的程序将不会终止,直到所有查询都已处理或超时。它就是这样儿的。我的猜测是这与垃圾收集器 (GC) 有关,它可能在非后台线程中运行,因此无法取消/终止。

编辑:(几天后)当我查看getaddrinfo 的手册页时,原因就很明显了。该函数返回一个链表到结果。这个列表当然是在堆上分配的,并且必须在某个时候释放以避免内存泄漏。该函数是 freeaddrinfo

无论如何,再次感谢 Evk!

那么我们如何在超时的情况下并行触发多个 DNS 查询(使用 Mono)?简单的!可以在 Task 中调用此函数,它会很乐意服从 WaitAll 超时:

private static string host(string query)
{
    ProcessStartInfo psi = new ProcessStartInfo("host", query);
    psi.UseShellExecute = false;
    psi.RedirectStandardOutput = true;
    Process p = Process.Start(psi);
    return p.StandardOutput.ReadToEnd();
}

关于.Net 和 Mono 中的 C# Task.WaitAll(),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/44900338/

相关文章:

php - 如何使用 PHP 从浏览器启动应用程序?

linux - 如何在Linux中访问并行端口

linux - 打印指针 : can the leading 0x be eliminated?

c# - Xamarin Forms 从 PCL 请求互联网许可 Android 6

c# - 禁用将项目添加到集合

java - 'a'时间一个端口可以处理多少个请求

c++ - 在 C++11 中,如何不向线程传递参数?

python - 服务器关闭之前后台线程未启动

C# 将作为泛型对象返回的数组转换为不同的基础类型

c# - 为什么编译器会放过这个错误?