Auto status change to "Under Review"
| @@ -0,0 +1,73 | |||||
|
|
1 | using System; | |||
|
|
2 | using System.Threading; | |||
|
|
3 | using System.Threading.Tasks; | |||
|
|
4 | ||||
|
|
5 | namespace Implab.Components { | |||
|
|
6 | public abstract class PollingComponent : RunnableComponent { | |||
|
|
7 | ||||
|
|
8 | readonly Timer m_timer; | |||
|
|
9 | ||||
|
|
10 | readonly CancellationTokenSource m_cancellation = new CancellationTokenSource(); | |||
|
|
11 | ||||
|
|
12 | /// <summary> | |||
|
|
13 | /// Poll interval in milliseconds. | |||
|
|
14 | /// </summary> | |||
|
|
15 | /// <returns></returns> | |||
|
|
16 | public int Interval { get; set; } | |||
|
|
17 | ||||
|
|
18 | /// <summary> | |||
|
|
19 | /// Delay to the first poll after start in milliseconds | |||
|
|
20 | /// </summary> | |||
|
|
21 | /// <returns></returns> | |||
|
|
22 | public int Delay { get; set; } | |||
|
|
23 | ||||
|
|
24 | /// <summary> | |||
|
|
25 | /// Indicates how to handle unhandled exceptions in <see cref="Poll()"/> method. | |||
|
|
26 | /// </summary> | |||
|
|
27 | /// <returns></returns> | |||
|
|
28 | public bool FailOnError { get; set; } | |||
|
|
29 | ||||
|
|
30 | /// <summary> | |||
|
|
31 | /// Event for the unhandled exceptions in <see cref="Poll()"/> method. | |||
|
|
32 | /// </summary> | |||
|
|
33 | public event EventHandler<UnhandledExceptionEventArgs> UnhandledException; | |||
|
|
34 | ||||
|
|
35 | protected PollingComponent(bool initialized) : base(initialized) { | |||
|
|
36 | m_timer = new Timer(OnTimer); | |||
|
|
37 | } | |||
|
|
38 | ||||
|
|
39 | protected override void RunInternal() { | |||
|
|
40 | ScheduleNextPoll(Delay); | |||
|
|
41 | } | |||
|
|
42 | ||||
|
|
43 | ||||
|
|
44 | //TODO override stop | |||
|
|
45 | ||||
|
|
46 | protected abstract Task Poll(CancellationToken ct); | |||
|
|
47 | ||||
|
|
48 | void ScheduleNextPoll(int timeout) { | |||
|
|
49 | lock (SynchronizationObject) { | |||
|
|
50 | if (State == ExecutionState.Running) | |||
|
|
51 | m_timer.Change(timeout, Timeout.Infinite); | |||
|
|
52 | } | |||
|
|
53 | } | |||
|
|
54 | ||||
|
|
55 | void OnTimer(object state) { | |||
|
|
56 | try { | |||
|
|
57 | Poll(m_cancellation.Token); | |||
|
|
58 | } catch (Exception e) { | |||
|
|
59 | UnhandledException.DispatchEvent(this, new UnhandledExceptionEventArgs(e, false)); | |||
|
|
60 | if (FailOnError) | |||
|
|
61 | Fail(e); | |||
|
|
62 | } | |||
|
|
63 | ScheduleNextPoll(Interval); | |||
|
|
64 | } | |||
|
|
65 | ||||
|
|
66 | protected override void Dispose(bool disposing) { | |||
|
|
67 | if (disposing) | |||
|
|
68 | Safe.Dispose(m_timer, m_cancellation); | |||
|
|
69 | base.Dispose(disposing); | |||
|
|
70 | } | |||
|
|
71 | ||||
|
|
72 | } | |||
|
|
73 | } No newline at end of file | |||
General Comments 3
You need to be logged in to leave comments.
Login now