[Test][UserEvents] Add Multithreaded scenario

Author: mdh1418

src/tests/tracing/userevents/multithread/multithread.cs

@@ -0,0 +1,106 @@
+// Licensed to the .NET Foundation under one or more agreements.
+// The .NET Foundation licenses this file to you under the MIT license.
+
+using System;
+using System.Collections.Generic;
+using System.Diagnostics;
+using System.Diagnostics.Tracing;
+using System.Threading;
+using System.Threading.Tasks;
+using Tracing.UserEvents.Tests.Common;
+using Microsoft.Diagnostics.Tracing;
+
+namespace Tracing.UserEvents.Tests.MultiThread
+{
+    [EventSource(Name = "DemoMultiThread")]
+    public sealed class MultiThreadEventSource : EventSource
+    {
+        public static readonly MultiThreadEventSource Log = new MultiThreadEventSource();
+
+        private MultiThreadEventSource() {}
+
+        [Event(1, Level = EventLevel.Informational)]
+        public void WorkerEvent(int workerId)
+        {
+            WriteEvent(1, workerId);
+        }
+    }
+
+    public static class MultiThread
+    {
+        private const int WorkerCount = 4;
+
+        public static void MultiThreadTracee()
+        {
+            Task[] tasks = new Task[WorkerCount];
+
+            for (int i = 0; i < WorkerCount; i++)
+            {
+                int workerId = i;
+                tasks[i] = Task.Run(() =>
+                {
+                    MultiThreadEventSource.Log.WorkerEvent(workerId);
+                });
+            }
+
+            Task.WaitAll(tasks);
+        }
+
+        private static readonly Func<EventPipeEventSource, bool> s_traceValidator = source =>
+        {
+            HashSet<int> seenWorkers = new HashSet<int>();
+
+            source.Dynamic.All += (TraceEvent e) =>
+            {
+                if (!string.Equals(e.ProviderName, "DemoMultiThread", StringComparison.Ordinal))
+                {
+                    return;
+                }
+
+                if (e.EventName is not "WorkerEvent")
+                {
+                    return;
+                }
+
+                int workerId = -1;
+                try
+                {
+                    workerId = (int)(e.PayloadByName("workerId") ?? -1);
+                }
+                catch (Exception ex)
+                {
+                    Console.Error.WriteLine($"Exception while reading workerId payload: {ex}");
+                }
+
+                if (workerId >= 0)
+                {
+                    seenWorkers.Add(workerId);
+                }
+            };
+
+            source.Process();
+
+            for (int i = 0; i < WorkerCount; i++)
+            {
+                if (!seenWorkers.Contains(i))
+                {
+                    Console.Error.WriteLine($"Did not observe event for worker {i}.");
+                    return false;
+                }
+            }
+
+            return true;
+        };
+
+        public static int Main(string[] args)
+        {
+            if (args.Length > 0 && args[0].Equals("tracee", StringComparison.OrdinalIgnoreCase))
+            {
+                MultiThreadTracee();
+                return 0;
+            }
+
+            return UserEventsTestRunner.Run("multithread", typeof(MultiThread).Assembly.Location, s_traceValidator);
+        }
+    }
+}

src/tests/tracing/userevents/multithread/multithread.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+  <PropertyGroup>
+    <CLRTestTargetUnsupported Condition="'$(TargetOS)' != 'linux' or ('$(TargetArchitecture)' != 'x64' and '$(TargetArchitecture)' != 'arm64')">true</CLRTestTargetUnsupported>
+    <RequiresProcessIsolation>true</RequiresProcessIsolation>
+    <ReferenceXUnitWrapperGenerator>false</ReferenceXUnitWrapperGenerator>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <Compile Include="$(MSBuildProjectName).cs" />
+    <ProjectReference Include="../common/userevents_common.csproj" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <Content Include="multithread.script">
+      <CopyToOutputDirectory>Always</CopyToOutputDirectory>
+      <TargetPath>multithread.script</TargetPath>
+    </Content>
+  </ItemGroup>
+</Project>

src/tests/tracing/userevents/multithread/multithread.script

@@ -0,0 +1,2 @@
+let DemoMultiThread_flags = new_dotnet_provider_flags();
+record_dotnet_provider("DemoMultiThread", 0x0, 5, DemoMultiThread_flags);