1
0

NewThreadSchedulerTest.cs 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121
  1. // Copyright (c) Microsoft Open Technologies, Inc. All rights reserved. See License.txt in the project root for license information.
  2. using System;
  3. using System.Diagnostics;
  4. using System.Reactive.Concurrency;
  5. using System.Reactive.Disposables;
  6. using System.Threading;
  7. using Microsoft.Reactive.Testing;
  8. using Xunit;
  9. namespace ReactiveTests.Tests
  10. {
  11. #if !NO_THREAD
  12. public class NewThreadSchedulerTest
  13. {
  14. [Fact]
  15. public void NewThread_ArgumentChecking()
  16. {
  17. ReactiveAssert.Throws<ArgumentNullException>(() => new NewThreadScheduler(null));
  18. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.Schedule<int>(42, default(Func<IScheduler, int, IDisposable>)));
  19. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.Schedule<int>(42, DateTimeOffset.Now, default(Func<IScheduler, int, IDisposable>)));
  20. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.Schedule<int>(42, TimeSpan.Zero, default(Func<IScheduler, int, IDisposable>)));
  21. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.SchedulePeriodic<int>(42, TimeSpan.FromSeconds(1), default(Func<int, int>)));
  22. ReactiveAssert.Throws<ArgumentNullException>(() => NewThreadScheduler.Default.ScheduleLongRunning<int>(42, default(Action<int, ICancelable>)));
  23. ReactiveAssert.Throws<ArgumentOutOfRangeException>(() => NewThreadScheduler.Default.SchedulePeriodic<int>(42, TimeSpan.FromSeconds(-1), _ => _));
  24. }
  25. [Fact]
  26. public void NewThread_Now()
  27. {
  28. var res = NewThreadScheduler.Default.Now - DateTime.Now;
  29. Assert.True(res.Seconds < 1);
  30. }
  31. #if !NO_THREAD
  32. [Fact]
  33. public void NewThread_ScheduleAction()
  34. {
  35. var id = Thread.CurrentThread.ManagedThreadId;
  36. var nt = NewThreadScheduler.Default;
  37. var evt = new ManualResetEvent(false);
  38. nt.Schedule(() => { Assert.NotEqual(id, Thread.CurrentThread.ManagedThreadId); evt.Set(); });
  39. evt.WaitOne();
  40. }
  41. #if !SILVERLIGHT
  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. #endif
  56. #if !NO_PERF
  57. #if !NO_STOPWATCH
  58. [Fact]
  59. public void Stopwatch()
  60. {
  61. StopwatchTest.Run(NewThreadScheduler.Default);
  62. }
  63. #endif
  64. #endif
  65. [Fact]
  66. public void NewThread_Periodic()
  67. {
  68. var n = 0;
  69. var e = new ManualResetEvent(false);
  70. var d = NewThreadScheduler.Default.SchedulePeriodic(TimeSpan.FromMilliseconds(25), () =>
  71. {
  72. if (Interlocked.Increment(ref n) == 10)
  73. e.Set();
  74. });
  75. if (!e.WaitOne(10000))
  76. Assert.True(false);
  77. d.Dispose();
  78. }
  79. #if !NO_THREAD
  80. [Fact]
  81. public void NewThread_Periodic_NonReentrant()
  82. {
  83. var n = 0;
  84. var fail = false;
  85. var d = NewThreadScheduler.Default.SchedulePeriodic(0, TimeSpan.FromMilliseconds(50), x =>
  86. {
  87. try
  88. {
  89. if (Interlocked.Increment(ref n) > 1) // Without an AsyncLock this would fail.
  90. fail = true;
  91. Thread.Sleep(100);
  92. return x + 1;
  93. }
  94. finally
  95. {
  96. Interlocked.Decrement(ref n);
  97. }
  98. });
  99. Thread.Sleep(500);
  100. d.Dispose();
  101. Assert.False(fail);
  102. }
  103. #endif
  104. }
  105. #endif
  106. }