【C#】【多线程】【04-使用任务平行库】05-将EAP模式转换为任务

## 将EAP模式转换为任务

关于 基于事件的异步模式（Event-based Asynchronous Pattern，简称EAP） 的实现方法可以参照<a href="http://liujiajia.me/#/blog/details/csharp-multi-threading-03-threadpool-07-backgroundworker" target="_blank">【C#】【多线程】【03-使用线程池】07-使用BackgroundWorker组件</a>

可以使用`TaskCompletionSource`类型将EAP转换为Task。

```csharp
/// <summary>
/// 将EAP模式转换为任务
/// </summary>
/// <param name="args"></param>
static void Main(string[] args)
{
    // 主要是使用TaskCompletionSource类型
    // T是异步处理返回结果类型
    var tcs = new TaskCompletionSource<int>();
    var worker = new BackgroundWorker();
    worker.DoWork += (sender, eventArgs) =>
    {
        eventArgs.Result = TaskMethod("Background worker", 5);
    };

worker.RunWorkerCompleted += (sender, eventArgs) =>
    {
        if (eventArgs.Error != null)
        {
            tcs.SetException(eventArgs.Error);
        }
        else if (eventArgs.Cancelled)
        {
            tcs.SetCanceled();
        }
        else
        {
            try
            {
                // 将SetResult方法封装在try-catch中，保证发生错误时仍然会设置给任务完成源对象
                // 若发生异常导致没有执行SetResult，则程序会一直阻塞在获取Task结果那里(tcs.Task.Result)
                tcs.SetResult((int)eventArgs.Result);
            }
            catch (Exception)
            {
                tcs.SetResult(0);
            }
        }
    };

worker.RunWorkerAsync();
    int result = tcs.Task.Result;

Console.WriteLine($"Result is: {result}");
    Console.ReadLine();
}

static int TaskMethod(string name, int seconds)
{
    Console.WriteLine($"Task {name} is running on a thread id {Thread.CurrentThread.ManagedThreadId}. " +
        $"Is thread pool thread: {Thread.CurrentThread.IsThreadPoolThread}");
    Thread.Sleep(TimeSpan.FromSeconds(seconds));
    return 42 * seconds;
}
```

打印结果

```
Task Background worker is running on a thread id 3. Is thread pool thread: True
Result is: 210
```

← 上一篇

【C#】【多线程】【04-使用任务平行库】05-将EAP模式转换为任务

目录

关联博客