-
Notifications
You must be signed in to change notification settings - Fork 26
/
ThreadPoolLogger.cs
105 lines (83 loc) · 3.14 KB
/
ThreadPoolLogger.cs
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
using System;
using System.Threading;
using System.Threading.Tasks;
namespace ThreadPoolMonitor
{
class ThreadPoolLogger : IDisposable
{
private TimeSpan _logFrequency;
private bool _disposed;
public ThreadPoolLogger(TimeSpan logFrequency)
{
if (logFrequency <= TimeSpan.Zero)
{
throw new ArgumentOutOfRangeException("logFrequency");
}
_logFrequency = logFrequency;
StartLogging();
}
private async void StartLogging()
{
try
{
while (!_disposed)
{
await Task.Delay(_logFrequency);
var stats = GetThreadPoolStats();
LogUsage(stats);
}
}
catch(Exception)
{
}
}
protected virtual void LogUsage(ThreadPoolUsageStats stats)
{
string message = string.Format("[{0}] IOCP:(Busy={1},Min={2},Max={3}), WORKER:(Busy={4},Min={5},Max={6}), Local CPU: {7}",
DateTimeOffset.UtcNow.ToString("u"),
stats.BusyIoThreads, stats.MinIoThreads, stats.MaxIoThreads,
stats.BusyWorkerThreads, stats.MinWorkerThreads, stats.MaxWorkerThreads,
PerfCounterHelper.GetSystemCPU()
);
Console.WriteLine(message);
}
/// <summary>
/// Returns the current thread pool usage statistics for the CURRENT AppDomain/Process
/// </summary>
public static ThreadPoolUsageStats GetThreadPoolStats()
{
//BusyThreads = TP.GetMaxThreads() –TP.GetAVailable();
//If BusyThreads >= TP.GetMinThreads(), then threadpool growth throttling is possible.
int maxIoThreads, maxWorkerThreads;
ThreadPool.GetMaxThreads(out maxWorkerThreads, out maxIoThreads);
int freeIoThreads, freeWorkerThreads;
ThreadPool.GetAvailableThreads(out freeWorkerThreads, out freeIoThreads);
int minIoThreads, minWorkerThreads;
ThreadPool.GetMinThreads(out minWorkerThreads, out minIoThreads);
int busyIoThreads = maxIoThreads - freeIoThreads;
int busyWorkerThreads = maxWorkerThreads - freeWorkerThreads;
return new ThreadPoolUsageStats
{
BusyIoThreads = busyIoThreads,
MinIoThreads = minIoThreads,
MaxIoThreads = maxIoThreads,
BusyWorkerThreads = busyWorkerThreads,
MinWorkerThreads = minWorkerThreads,
MaxWorkerThreads = maxWorkerThreads,
};
}
public void Dispose()
{
_disposed = true;
}
}
public struct ThreadPoolUsageStats
{
public int BusyIoThreads { get; set; }
public int MinIoThreads { get; set; }
public int MaxIoThreads { get; set; }
public int BusyWorkerThreads { get; set; }
public int MinWorkerThreads { get; set; }
public int MaxWorkerThreads { get; set; }
}
}