.Wait() 导致 TaskCanceledException

Question

我有一个发送电子邮件的功能，如下所示：

public async Task SendEmail(string from, string to, string subject, string body, bool isBodyHtml = false)
        {
            await Task.Run(() =>
            {
                using (SmtpClient smtp = new SmtpClient(host, port))
                {
                    smtp.Credentials = new NetworkCredential(userName, password);
                    smtp.EnableSsl = true;
                    smtp.SendCompleted += SmtpOnSendCompleted;
                    MailMessage message = new MailMessage(from, to, subject, body);
                    message.IsBodyHtml = isBodyHtml;
                    smtp.Send(message);
                }
            }).ContinueWith(task =>
            {
                LoggingService.Instance.BusinessLogger.Error(task.Exception.Flatten().InnerException);

            }, TaskContinuationOptions.OnlyOnFaulted);
        }

如您所见，它不是“真正的异步”，而是“延迟执行”，因此我可以调用此方法，并且不会阻塞当前调用线程。

现在，我有时需要一种方法来等待电子邮件发送完毕，然后再继续。所以我这样调用我的 SendMail() 方法：

EmailService.Instance.SendEmail("from@blah.com", "to@blah.com", "Subject", "Body text").Wait();

最后带有 .Wait()。

由于某种原因使用 .Wait() - 试图强制同步执行，导致异常：

System.Threading.Tasks.TaskCanceledException：任务被取消

问题：

1) 为什么会出现此异常？

2) 如何强制同步执行该方法？

谢谢

Answer 1

1) 为什么会出现此异常？

您收到异常是因为，

• 原始任务顺利完成，没有任何错误
• 您的 continuation 将 TaskContinuationOptions 设置为 TaskContinuationOptions.OnlyOnFaulted
• 由于原始 Task 的执行没有错误，您会收到 AggregateException: A task was cancelled。 因为继续没有执行并且它被取消了

2) 如何强制同步执行此方法？

你可以强制同步执行，

• 使用Task.Wait Method (TimeSpan)
• 使用Task.RunSynchronously Method ()

例如

var task = new Task(() => { ... });
task.RunSynchronously();

通过注释/取消注释虚拟异常来检查以下程序在原始任务中抛出错误以及原始任务完成时的行为方式。您可以在http://rextester.com/执行以下程序

using System;
using System.Threading.Tasks;

namespace Rextester
{
    public class Program
    {
        public static void Main(string[] args)
        {
            try
            {
                DoSomething().Wait();
            }
            catch (AggregateException ex)
            {
                Console.WriteLine(ex.InnerException.Message);
            }

            Console.WriteLine("DoSomething completed");
        }

        public static async Task DoSomething()
        {
            await Task.Factory.StartNew(() =>
            {
                System.Threading.Thread.Sleep(1000);
                Console.WriteLine("Doing Something");
                // throw new Exception("Something wen't wrong");
            }).ContinueWith(task =>
            {
                Console.WriteLine(task.Exception.InnerException.Message);
            }, TaskContinuationOptions.OnlyOnFaulted);
        }
    }
}

如果您只是在使用 ContinueWith 方法出现任何问题时才记录异常，那么您可以摆脱该 ContinueWith 并放置一个 try catch块在原始任务中捕获任何异常并记录它们。

static void Main(string[] args)
{
    DoSomething().Wait();
    Console.WriteLine("DoSomething completed");
    Console.ReadKey();
}

public static async Task DoSomething()
{
    await Task.Factory.StartNew(() =>
    {
        try
        {
            System.Threading.Thread.Sleep(1000);
            Console.WriteLine("Doing Something");
            throw new Exception("Something wen't wrong");
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    });
}

否则，如果您想在原始Task完成后做一些额外的工作，您可以按照以下方式进行。

namespace SO
{
    using System;
    using System.Threading.Tasks;

    class Program
    {
        static void Main(string[] args)
        {
            DoSomething().Wait();
            Console.WriteLine("DoSomething completed");
            Console.ReadKey();
        }

        public static async Task DoSomething()
        {
            await Task.Factory.StartNew(() =>
            {
                System.Threading.Thread.Sleep(1000);
                Console.WriteLine("Doing Something");
                // throw new Exception("Something wen't wrong");
            }).ContinueWith(task =>
            {
                if (task.Status == TaskStatus.Faulted)
                {
                    // log exception
                    Console.WriteLine(task.Exception.InnerException.Message);
                }
                else if (task.Status == TaskStatus.RanToCompletion)
                {
                    // do continuation work here
                }
            });
        }
    }
}