-
Notifications
You must be signed in to change notification settings - Fork 28
/
UnconstrainedFrameRateGifRecorder.cs
131 lines (105 loc) · 3.62 KB
/
UnconstrainedFrameRateGifRecorder.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
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
using System;
using System.Threading;
using System.Threading.Tasks;
namespace Screna
{
public class UnconstrainedFrameRateGifRecorder : IRecorder
{
#region Fields
GifWriter VideoEncoder = null;
IImageProvider ImageProvider = null;
Thread RecordThread;
ManualResetEvent StopCapturing = new ManualResetEvent(false),
ContinueCapturing = new ManualResetEvent(false);
#endregion
~UnconstrainedFrameRateGifRecorder() { Stop(); }
public UnconstrainedFrameRateGifRecorder(GifWriter Encoder, IImageProvider ImageProvider)
{
// Init Fields
this.ImageProvider = ImageProvider;
VideoEncoder = Encoder;
// RecordThread Init
if (ImageProvider != null)
RecordThread = new Thread(Record)
{
Name = "Captura.Record",
IsBackground = true
};
// Not Actually Started, Waits for ContinueThread to be Set
RecordThread?.Start();
}
public event Action<Exception> RecordingStopped;
public void Start(int Delay = 0)
{
new Thread(e =>
{
try
{
Thread.Sleep((int)e);
if (RecordThread != null) ContinueCapturing.Set();
}
catch (Exception E) { RecordingStopped?.Invoke(E); }
}).Start(Delay);
}
public void Stop()
{
// Resume if Paused
ContinueCapturing?.Set();
// Video
if (RecordThread != null)
{
if (StopCapturing != null && !StopCapturing.SafeWaitHandle.IsClosed)
StopCapturing.Set();
if (!RecordThread.Join(500))
RecordThread.Abort();
RecordThread = null;
}
if (ImageProvider != null)
{
ImageProvider.Dispose();
ImageProvider = null;
}
// WaitHandles
if (StopCapturing != null && !StopCapturing.SafeWaitHandle.IsClosed)
{
StopCapturing.Dispose();
StopCapturing = null;
}
if (ContinueCapturing != null && !ContinueCapturing.SafeWaitHandle.IsClosed)
{
ContinueCapturing.Dispose();
ContinueCapturing = null;
}
// Writers
if (VideoEncoder != null)
{
VideoEncoder.Dispose();
VideoEncoder = null;
}
}
public void Pause() { if (RecordThread != null) ContinueCapturing.Reset(); }
void Record()
{
try
{
var LastFrameWriteTime = DateTime.MinValue;
Task LastFrameWriteTask = null;
while (!StopCapturing.WaitOne(0) && ContinueCapturing.WaitOne())
{
var Frame = ImageProvider.Capture();
var Delay = LastFrameWriteTime == DateTime.MinValue ? 0
: (int)(DateTime.Now - LastFrameWriteTime).TotalMilliseconds;
LastFrameWriteTime = DateTime.Now;
LastFrameWriteTask = VideoEncoder.WriteFrameAsync(Frame, Delay);
}
// Wait for the last frame is written
LastFrameWriteTask?.Wait();
}
catch (Exception E)
{
Stop();
RecordingStopped?.Invoke(E);
}
}
}
}