Report ThreadPool stats

CHANGELOG.md

@@ -6,6 +6,7 @@
 
 - Events no longer get dropped because of non-serializable contexts or attachments ([#1401](https://github.com/getsentry/sentry-dotnet/pull/1401))
 - Add MemoryInfo to sentry event ([#1337](https://github.com/getsentry/sentry-dotnet/pull/1337))
+- Report ThreadPool stats ([#1399](https://github.com/getsentry/sentry-dotnet/pull/1399))
 
 ## 3.12.2
 

src/Sentry/Internal/MainSentryEventProcessor.cs

@@ -13,6 +13,7 @@ internal class MainSentryEventProcessor : ISentryEventProcessor
         internal const string CultureInfoKey = "Current Culture";
         internal const string CurrentUiCultureKey = "Current UI Culture";
         internal const string MemoryInfoKey = "Memory Info";
+        internal const string ThreadPoolInfoKey = "ThreadPool Info";
 
         private readonly Enricher _enricher;
 
@@ -56,6 +57,7 @@ public SentryEvent Process(SentryEvent @event)
             }
 
             AddMemoryInfo(@event.Contexts);
+            AddThreadPoolInfo(@event.Contexts);
             if (@event.ServerName == null)
             {
                 // Value set on the options take precedence over device name.
@@ -170,6 +172,20 @@ private void AddMemoryInfo(Contexts contexts)
 #endif
         }
 
+        private void AddThreadPoolInfo(Contexts contexts)
+        {
+            ThreadPool.GetMinThreads(out var minWorkerThreads, out var minCompletionPortThreads);
+            ThreadPool.GetMaxThreads(out var maxWorkerThreads, out var maxCompletionPortThreads);
+            ThreadPool.GetAvailableThreads(out var availableWorkerThreads, out var availableCompletionPortThreads);
+            contexts[ThreadPoolInfoKey] = new ThreadPoolInfo(
+                minWorkerThreads,
+                minCompletionPortThreads,
+                maxWorkerThreads,
+                maxCompletionPortThreads,
+                availableWorkerThreads,
+                availableCompletionPortThreads);
+        }
+
         private static IDictionary<string, string>? CultureInfoToDictionary(CultureInfo cultureInfo)
         {
             var dic = new Dictionary<string, string>();
@@ -190,5 +206,4 @@ private void AddMemoryInfo(Contexts contexts)
             return dic.Count > 0 ? dic : null;
         }
     }
-
 }

src/Sentry/Internal/ThreadPoolInfo.cs

@@ -0,0 +1,45 @@
+using System.Text.Json;
+using Sentry.Extensibility;
+
+namespace Sentry
+{
+    internal sealed class ThreadPoolInfo : IJsonSerializable
+    {
+        public ThreadPoolInfo(
+            int minWorkerThreads,
+            int minCompletionPortThreads,
+            int maxWorkerThreads,
+            int maxCompletionPortThreads,
+            int availableWorkerThreads,
+            int availableCompletionPortThreads)
+        {
+            MinWorkerThreads = minWorkerThreads;
+            MinCompletionPortThreads = minCompletionPortThreads;
+            MaxWorkerThreads = maxWorkerThreads;
+            MaxCompletionPortThreads = maxCompletionPortThreads;
+            AvailableWorkerThreads = availableWorkerThreads;
+            AvailableCompletionPortThreads = availableCompletionPortThreads;
+        }
+
+        public int MinWorkerThreads { get; }
+        public int MinCompletionPortThreads { get; }
+        public int MaxWorkerThreads { get; }
+        public int MaxCompletionPortThreads { get; }
+        public int AvailableWorkerThreads { get; }
+        public int AvailableCompletionPortThreads { get; }
+
+        public void WriteTo(Utf8JsonWriter writer, IDiagnosticLogger? logger)
+        {
+            writer.WriteStartObject();
+
+            writer.WriteNumber("minWorkerThreads", MinWorkerThreads);
+            writer.WriteNumber("minCompletionPortThreads", MinCompletionPortThreads);
+            writer.WriteNumber("maxWorkerThreads", MaxWorkerThreads);
+            writer.WriteNumber("maxCompletionPortThreads", MaxCompletionPortThreads);
+            writer.WriteNumber("availableWorkerThreads", AvailableWorkerThreads);
+            writer.WriteNumber("availableCompletionPortThreads", AvailableCompletionPortThreads);
+
+            writer.WriteEndObject();
+        }
+    }
+}

test/Sentry.Tests/Internals/MainSentryEventProcessorTests.cs

@@ -38,6 +38,22 @@ public void Process_SendDefaultPiiTrueIdEnvironmentDefault_UserNameSet()
         Assert.Equal(Environment.UserName, evt.User.Username);
     }
 
+    [Fact]
+    public void EnsureThreadPoolInfoExists()
+    {
+        var evt = new SentryEvent();
+
+        _fixture.SentryOptions.SendDefaultPii = true;
+        var sut = _fixture.GetSut();
+
+        _ = sut.Process(evt);
+        var info = (ThreadPoolInfo)evt.Contexts[MainSentryEventProcessor.ThreadPoolInfoKey];
+        Assert.NotEqual(0, info.MinWorkerThreads);
+        Assert.NotEqual(0, info.MinCompletionPortThreads);
+        Assert.NotEqual(0, info.MaxWorkerThreads);
+        Assert.NotEqual(0, info.MaxCompletionPortThreads);
+    }
+
 #if NETCOREAPP3_1_OR_GREATER
     [Fact]
     public void EnsureMemoryInfoExists()