ControlSchedulerTest.cs 9.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297
  1. // Licensed to the .NET Foundation under one or more agreements.
  2. // The .NET Foundation licenses this file to you under the MIT License.
  3. // See the LICENSE file in the project root for more information.
  4. #if HAS_WINFORMS
  5. using System;
  6. using System.Reactive.Concurrency;
  7. using System.Reactive.Disposables;
  8. using System.Diagnostics;
  9. using System.Threading;
  10. using System.Windows.Forms;
  11. using Microsoft.VisualStudio.TestTools.UnitTesting;
  12. using Microsoft.Reactive.Testing;
  13. using Assert = Xunit.Assert;
  14. namespace ReactiveTests.Tests
  15. {
  16. [TestClass]
  17. public class ControlSchedulerTest
  18. {
  19. [TestMethod]
  20. public void Ctor_ArgumentChecking()
  21. {
  22. ReactiveAssert.Throws<ArgumentNullException>(() => new ControlScheduler(null));
  23. }
  24. [TestMethod]
  25. public void Control()
  26. {
  27. var lbl = new Label();
  28. Assert.Same(lbl, new ControlScheduler(lbl).Control);
  29. }
  30. [TestMethod]
  31. public void Now()
  32. {
  33. var res = new ControlScheduler(new Label()).Now - DateTime.Now;
  34. Assert.True(res.Seconds < 1);
  35. }
  36. [TestMethod]
  37. public void Schedule_ArgumentChecking()
  38. {
  39. var s = new ControlScheduler(new Label());
  40. ReactiveAssert.Throws<ArgumentNullException>(() => s.Schedule(42, default(Func<IScheduler, int, IDisposable>)));
  41. ReactiveAssert.Throws<ArgumentNullException>(() => s.Schedule(42, TimeSpan.FromSeconds(1), default(Func<IScheduler, int, IDisposable>)));
  42. ReactiveAssert.Throws<ArgumentNullException>(() => s.Schedule(42, DateTimeOffset.Now, default(Func<IScheduler, int, IDisposable>)));
  43. }
  44. [TestMethod]
  45. public void Schedule()
  46. {
  47. using (WinFormsTestUtils.RunTest(out var lbl))
  48. {
  49. var evt = new ManualResetEvent(false);
  50. var id = Thread.CurrentThread.ManagedThreadId;
  51. var sch = new ControlScheduler(lbl);
  52. sch.Schedule(() => { lbl.Text = "Okay"; Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); });
  53. sch.Schedule(() => { Assert.Equal("Okay", lbl.Text); Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); evt.Set(); });
  54. evt.WaitOne();
  55. }
  56. }
  57. [TestMethod]
  58. public void ScheduleError()
  59. {
  60. using (WinFormsTestUtils.RunTest(out var lbl))
  61. {
  62. var evt = new ManualResetEvent(false);
  63. var ex = new Exception();
  64. lbl.Invoke(new Action(() =>
  65. {
  66. Application.ThreadException += (o, e) =>
  67. {
  68. Assert.Same(ex, e.Exception);
  69. evt.Set();
  70. };
  71. }));
  72. var sch = new ControlScheduler(lbl);
  73. sch.Schedule(() => { throw ex; });
  74. evt.WaitOne();
  75. }
  76. }
  77. [TestMethod]
  78. public void ScheduleRelative()
  79. {
  80. ScheduleRelative_(TimeSpan.FromSeconds(0.1));
  81. }
  82. [TestMethod]
  83. public void ScheduleRelative_Zero()
  84. {
  85. ScheduleRelative_(TimeSpan.Zero);
  86. }
  87. private void ScheduleRelative_(TimeSpan delay)
  88. {
  89. using (WinFormsTestUtils.RunTest(out var lbl))
  90. {
  91. var evt = new ManualResetEvent(false);
  92. var id = Thread.CurrentThread.ManagedThreadId;
  93. var sch = new ControlScheduler(lbl);
  94. sch.Schedule(delay, () =>
  95. {
  96. lbl.Text = "Okay";
  97. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  98. sch.Schedule(() =>
  99. {
  100. Assert.Equal("Okay", lbl.Text);
  101. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  102. evt.Set();
  103. });
  104. });
  105. evt.WaitOne();
  106. }
  107. }
  108. [TestMethod]
  109. public void ScheduleRelative_Nested()
  110. {
  111. using (WinFormsTestUtils.RunTest(out var lbl))
  112. {
  113. var evt = new ManualResetEvent(false);
  114. var id = Thread.CurrentThread.ManagedThreadId;
  115. var sch = new ControlScheduler(lbl);
  116. sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
  117. {
  118. sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
  119. {
  120. lbl.Text = "Okay";
  121. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  122. sch.Schedule(() =>
  123. {
  124. Assert.Equal("Okay", lbl.Text);
  125. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  126. evt.Set();
  127. });
  128. });
  129. });
  130. evt.WaitOne();
  131. }
  132. }
  133. [TestMethod]
  134. public void ScheduleRelative_Cancel()
  135. {
  136. using (WinFormsTestUtils.RunTest(out var lbl))
  137. {
  138. var evt = new ManualResetEvent(false);
  139. var id = Thread.CurrentThread.ManagedThreadId;
  140. var sch = new ControlScheduler(lbl);
  141. sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
  142. {
  143. lbl.Text = "Okay";
  144. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  145. var d = sch.Schedule(TimeSpan.FromSeconds(0.1), () =>
  146. {
  147. lbl.Text = "Oops!";
  148. });
  149. sch.Schedule(() =>
  150. {
  151. d.Dispose();
  152. });
  153. sch.Schedule(TimeSpan.FromSeconds(0.2), () =>
  154. {
  155. Assert.Equal("Okay", lbl.Text);
  156. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  157. evt.Set();
  158. });
  159. });
  160. evt.WaitOne();
  161. }
  162. }
  163. [TestMethod]
  164. public void SchedulePeriodic_ArgumentChecking()
  165. {
  166. var s = new ControlScheduler(new Label());
  167. ReactiveAssert.Throws<ArgumentNullException>(() => s.SchedulePeriodic(42, TimeSpan.FromSeconds(1), default(Func<int, int>)));
  168. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => s.SchedulePeriodic(42, TimeSpan.Zero, x => x));
  169. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => s.SchedulePeriodic(42, TimeSpan.FromMilliseconds(1).Subtract(TimeSpan.FromTicks(1)), x => x));
  170. }
  171. [TestMethod]
  172. public void SchedulePeriodic()
  173. {
  174. using (WinFormsTestUtils.RunTest(out var lbl))
  175. {
  176. var evt = new ManualResetEvent(false);
  177. var id = Thread.CurrentThread.ManagedThreadId;
  178. var sch = new ControlScheduler(lbl);
  179. var d = new SingleAssignmentDisposable();
  180. d.Disposable = sch.SchedulePeriodic(1, TimeSpan.FromSeconds(0.1), n =>
  181. {
  182. lbl.Text = "Okay " + n;
  183. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  184. if (n == 3)
  185. {
  186. d.Dispose();
  187. sch.Schedule(TimeSpan.FromSeconds(0.2), () =>
  188. {
  189. Assert.Equal("Okay 3", lbl.Text);
  190. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  191. evt.Set();
  192. });
  193. }
  194. if (n > 3)
  195. {
  196. Assert.True(false);
  197. }
  198. return n + 1;
  199. });
  200. evt.WaitOne();
  201. }
  202. }
  203. [TestMethod]
  204. public void SchedulePeriodic_Nested()
  205. {
  206. using (WinFormsTestUtils.RunTest(out var lbl))
  207. {
  208. var evt = new ManualResetEvent(false);
  209. var id = Thread.CurrentThread.ManagedThreadId;
  210. var sch = new ControlScheduler(lbl);
  211. sch.Schedule(() =>
  212. {
  213. lbl.Text = "Okay";
  214. var d = new SingleAssignmentDisposable();
  215. d.Disposable = sch.SchedulePeriodic(1, TimeSpan.FromSeconds(0.1), n =>
  216. {
  217. lbl.Text = "Okay " + n;
  218. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  219. if (n == 3)
  220. {
  221. d.Dispose();
  222. sch.Schedule(TimeSpan.FromSeconds(0.2), () =>
  223. {
  224. Assert.Equal("Okay 3", lbl.Text);
  225. Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId);
  226. evt.Set();
  227. });
  228. }
  229. return n + 1;
  230. });
  231. });
  232. evt.WaitOne();
  233. }
  234. }
  235. }
  236. }
  237. #endif