任务与 AsParallel()

Question

在 Stephen Toub 的书的第 33 页

http://www.microsoft.com/ download/en/details.aspx?id=19222

有代码

var pings = from addr in addrs.AsParallel().WithDegreeOfParallelism(16)
   select new Ping().Send(addr);
foreach (var ping in pings)
   Console.WriteLine("{0}: {1}", ping.Status, ping.Address);

，根据 Stephen 的说法，更好的版本

var pings = (from addr in addrs
    select new Ping().SendTask(addr, null)).ToArray();
Task.WaitAll(pings);
foreach (Task<PingReply> ping in pings)
    Console.WriteLine("{0}: {1}", ping.Result.Status, ping.Result.Address);

Stephen 说第二个选项更好，因为“任务抽象也可以用于表示 I/O 绑定操作，并且无需占用线程 但是任务

不是只使用底层的线程池（因此只是使用线程）吗？所以你实际上是在占用一个线程？

Answer 1

并非所有任务都代表要在线程上完成的工作。几乎任何从 TaskCompletionSource 返回的任务都代表一些“其他”的东西。如果我们深入研究 SendTask 方法，我们会发现它调用 SentTaskCore：

private static Task<PingReply> SendTaskCore(Ping ping, object userToken, Action<TaskCompletionSource<PingReply>> sendAsync)
    {
        // Validate we're being used with a real smtpClient.  The rest of the arg validation
        // will happen in the call to sendAsync.
        if (ping == null) throw new ArgumentNullException("ping");

        // Create a TaskCompletionSource to represent the operation
        var tcs = new TaskCompletionSource<PingReply>(userToken);

        // Register a handler that will transfer completion results to the TCS Task
        PingCompletedEventHandler handler = null;
        handler = (sender, e) => EAPCommon.HandleCompletion(tcs, e, () => e.Reply, () => ping.PingCompleted -= handler);
        ping.PingCompleted += handler;

        // Try to start the async operation.  If starting it fails (due to parameter validation)
        // unregister the handler before allowing the exception to propagate.
        try
        {
            sendAsync(tcs);
        }
        catch(Exception exc)
        {
            ping.PingCompleted -= handler;
            tcs.TrySetException(exc);
        }

        // Return the task to represent the asynchronous operation
        return tcs.Task;
    }

所以，不，它不会阻塞线程 - 它使用异步完成机制来避免占用一个线程。线。

---

来自 TaskCompletionSource 上的文档：

表示未绑定到委托的任务的生产者端，通过 Task 属性提供对消费者端的访问。

因此，正如它所说，它支持未绑定到委托的 Task - 它允许您将一个 Task 交给某人，然后编排该任务的完成方式，当完成涉及除执行委托之外的其他事情时。