我如何收听TPL TaskStarted/TaskCompleted ETW事件

Question

我有兴趣听ETW(Windows的事件跟踪)TPL事件,特别是我想知道什么时候Task开始以及何时停止.

这是我用于测试的示例程序:

   using System;
   using System.Collections.Generic;
   using System.Diagnostics.Tracing;
   using System.Linq;
   using System.Text;
   using System.Threading;
   using System.Threading.Tasks;

   namespace ConsoleApplication10
   {
      class Listener : EventListener
      {
         private static readonly Guid tplGuid = new Guid("2e5dba47-a3d2-4d16-8ee0-6671ffdcd7b5");

         protected override void OnEventSourceCreated(EventSource eventSource)
         {
            Console.WriteLine("Got guid: " + eventSource.Guid);
            EnableEvents(eventSource, EventLevel.LogAlways);
         }

         protected override void OnEventWritten(EventWrittenEventArgs eventData)
         {
            Console.WriteLine("Event: " + eventData.EventId);
         }
      }

      class Program
      {
         static void Main(string[] args)
         {
            using (var listener = new Listener())
            {
               Action doIt = null;
               doIt = () =>
               {
                  Thread.Sleep(1000);
                  Console.Write('.');
                  Task.Run(doIt);
               };
               Task.Run(doIt);

               Parallel.Invoke(() => Console.WriteLine("invoke"));

               Console.Read();
            }
         }
      }
   }

我的机器上的示例输出如下:

Got guid: 8e9f5090-2d75-4d03-8a81-e5afbf85daf1
Got guid: 2e5dba47-a3d2-4d16-8ee0-6671ffdcd7b5
Event: 3
invoke
Event: 4
.......

因此,Invoke方法会导致事件触发,但任务不会触发任何事件.查看任务源(例如参考源),代码看起来与Parallel.Invoke事件触发的方式没有什么不同.

上面有什么问题,或者,我如何监听TaskStarted和TaskCompleted事件(或任何与此相关的任务事件)？

Answer 1

你的问题让我想到了ETW(我一直想要研究一下).我能够使用Microsoft.Diagnostics.Tracing.TraceEvent NuGet库捕获"任务开始"和"任务结束",其中包含以下简单代码:

private static void Main(string[] args)
{
    Task.Run(() =>
    {
        using (var session = new TraceEventSession("TplCaptureSession"))
        {
            session.EnableProvider(new Guid("2e5dba47-a3d2-4d16-8ee0-6671ffdcd7b5"),
                                   TraceEventLevel.Always);

            session.Source.Dynamic.AddCallbackForProviderEvent("System.Threading.Tasks
                                                               .TplEventSource",
                "TaskExecute/Start", @event =>
                {
                    Console.WriteLine("Inside Task Started");
                });

            session.Source.Dynamic.AddCallbackForProviderEvent("System.Threading.Tasks
                                                   .TplEventSource", 
                "TaskExecute/Stop", @event =>
                {
                    Console.WriteLine("Inside Task Stopped");
                });

            session.Source.Process();
        }
    });

    var task = Task.Run(async () =>
    {
        await Task.Delay(20000);
    });

    task.Wait();
}

基本上会发生什么:

1. 我们开始新的实时事件捕获会话,使用TraceEventSession我们传递它TraceEventLevel.Always来打印所有消息(我们可以将其缩小到TranceEventLevel.Information,但是对于我选择所有的示例).

2. 我们通过传递它Guid来启用TplEventSource提供程序session.EnableProvider.

3. 我们注册一次要调用的回调TplEventSource(显然是TPL的事件源),TaskExecute/Start或者触发TaskExecute/Stop事件(从参考源获取)

4. 一旦我们进入活动,我们就会打印出来.

注意我的使用Task.Run只是因为session.Source.Process()是一个阻塞调用,我希望它在后台运行.