-
Notifications
You must be signed in to change notification settings - Fork 7
/
SmartPerformanceCounter.cs
81 lines (66 loc) · 2 KB
/
SmartPerformanceCounter.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
using System;
using System.Diagnostics;
using System.Threading.Tasks;
namespace it
{
public sealed partial class SmartPerformanceCounter : IDisposable
{
private readonly object @lock = new object();
private readonly Func<PerformanceCounter> factory;
private readonly TimeSpan time;
private long cpuCounterLastAccessedTimestamp;
private bool disposed;
private PerformanceCounter value;
public SmartPerformanceCounter(Func<PerformanceCounter> factory, TimeSpan time)
{
this.factory = factory ?? throw new ArgumentNullException(nameof(factory));
this.time = time;
}
public bool IsValueCreated { get; private set; }
public PerformanceCounter Value
{
get
{
lock (@lock)
{
if (!IsValueCreated)
{
value?.Dispose();
value = factory();
IsValueCreated = true;
}
}
cpuCounterLastAccessedTimestamp = Stopwatch.GetTimestamp();
return value;
}
}
public void Dispose()
{
if (disposed)
{
return;
}
disposed = true;
value?.Dispose();
}
public async Task FunctionAsync()
{
await Task.Delay(time).ConfigureAwait(false);
DoCleaningCheck();
}
private void DoCleaningCheck()
{
if (Stopwatch.GetTimestamp() - cpuCounterLastAccessedTimestamp <= time.Ticks)
{
return;
}
lock (@lock)
{
IsValueCreated = false;
value.Close();
value.Dispose();
value = null;
}
}
}
}