NewThreadSchedulerTest.cs 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  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. using System;
  5. using System.Diagnostics;
  6. using System.Reactive.Concurrency;
  7. using System.Threading;
  8. using Microsoft.Reactive.Testing;
  9. using Xunit;
  10. namespace ReactiveTests.Tests
  11. {
  12. #if !NO_THREAD
  13. public class NewThreadSchedulerTest
  14. {
  15. [Fact]
  16. public void NewThread_ArgumentChecking()
  17. {
  18. ReactiveAssert.Throws<ArgumentNullException>(() => new NewThreadScheduler(null));
  19. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.Schedule(42, default));
  20. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.Schedule(42, DateTimeOffset.Now, default));
  21. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.Schedule(42, TimeSpan.Zero, default));
  22. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.SchedulePeriodic(42, TimeSpan.FromSeconds(1), default));
  23. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.ScheduleLongRunning(42, default));
  24. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => NewThreadScheduler.Default.SchedulePeriodic(42, TimeSpan.FromSeconds(-1), _ => _));
  25. }
  26. [Fact]
  27. public void NewThread_Now()
  28. {
  29. var res = NewThreadScheduler.Default.Now - DateTime.Now;
  30. Assert.True(res.Seconds < 1);
  31. }
  32. #if !NO_THREAD
  33. [Fact]
  34. public void NewThread_ScheduleAction()
  35. {
  36. var id = Thread.CurrentThread.ManagedThreadId;
  37. var nt = NewThreadScheduler.Default;
  38. var evt = new ManualResetEvent(false);
  39. nt.Schedule(() => { Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); evt.Set(); });
  40. evt.WaitOne();
  41. }
  42. [Fact(Skip = "")]
  43. public void NewThread_ScheduleActionDue()
  44. {
  45. var id = Thread.CurrentThread.ManagedThreadId;
  46. var nt = NewThreadScheduler.Default;
  47. var evt = new ManualResetEvent(false);
  48. var sw = new Stopwatch();
  49. sw.Start();
  50. nt.Schedule(TimeSpan.FromSeconds(0.2), () => { sw.Stop(); Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); evt.Set(); });
  51. evt.WaitOne();
  52. Assert.True(sw.ElapsedMilliseconds > 180, "due " + sw.ElapsedMilliseconds);
  53. }
  54. #endif
  55. #if !NO_PERF
  56. [Fact]
  57. public void Stopwatch()
  58. {
  59. StopwatchTest.Run(NewThreadScheduler.Default);
  60. }
  61. #endif
  62. [Fact]
  63. public void NewThread_Periodic()
  64. {
  65. var n = 0;
  66. var e = new ManualResetEvent(false);
  67. var d = NewThreadScheduler.Default.SchedulePeriodic(TimeSpan.FromMilliseconds(25), () =>
  68. {
  69. if (Interlocked.Increment(ref n) == 10)
  70. {
  71. e.Set();
  72. }
  73. });
  74. if (!e.WaitOne(10000))
  75. {
  76. Assert.True(false);
  77. }
  78. d.Dispose();
  79. }
  80. #if !NO_THREAD
  81. [Fact]
  82. public void NewThread_Periodic_NonReentrant()
  83. {
  84. var n = 0;
  85. var fail = false;
  86. var d = NewThreadScheduler.Default.SchedulePeriodic(0, TimeSpan.FromMilliseconds(50), x =>
  87. {
  88. try
  89. {
  90. if (Interlocked.Increment(ref n) > 1) // Without an AsyncLock this would fail.
  91. {
  92. fail = true;
  93. }
  94. Thread.Sleep(100);
  95. return x + 1;
  96. }
  97. finally
  98. {
  99. Interlocked.Decrement(ref n);
  100. }
  101. });
  102. Thread.Sleep(500);
  103. d.Dispose();
  104. Assert.False(fail);
  105. }
  106. #endif
  107. }
  108. #endif
  109. }