annotate Implab.Test/AsyncTests.cs @ 117:8beee0d11de6 v2

pool refactoring
author cin
date Tue, 23 Dec 2014 19:48:47 +0300
parents d4e38929ce36
children 2573b562e328
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
77
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
1 using System;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
2 using System.Reflection;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
3 using System.Threading;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
4 using Implab.Parallels;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
5
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
6 #if MONO
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
7
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
8 using NUnit.Framework;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
9 using TestClassAttribute = NUnit.Framework.TestFixtureAttribute;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
10 using TestMethod = NUnit.Framework.TestAttribute;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
11
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
12 #else
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
13
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
14 using Microsoft.VisualStudio.TestTools.UnitTesting;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
15
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
16 #endif
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
17
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
18 namespace Implab.Test {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
19 [TestClass]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
20 public class AsyncTests {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
21 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
22 public void ResolveTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
23 int res = -1;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
24 var p = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
25 p.Then(x => res = x);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
26 p.Resolve(100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
27
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
28 Assert.AreEqual(100, res);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
29 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
30
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
31 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
32 public void RejectTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
33 int res = -1;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
34 Exception err = null;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
35
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
36 var p = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
37 p.Then(
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
38 x => res = x,
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
39 e => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
40 err = e;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
41 return -2;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
42 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
43 );
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
44 p.Reject(new ApplicationException("error"));
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
45
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
46 Assert.AreEqual(res, -1);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
47 Assert.AreEqual(err.Message, "error");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
48
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
49 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
50
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
51 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
52 public void CancelExceptionTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
53 var p = new Promise<bool>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
54 p.Cancel();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
55
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
56 var p2 = p.Cancelled(() => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
57 throw new ApplicationException("CANCELLED");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
58 });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
59
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
60 try {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
61 p2.Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
62 Assert.Fail();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
63 } catch (ApplicationException err) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
64 Assert.AreEqual("CANCELLED", err.InnerException.Message);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
65 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
66
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
67 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
68
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
69 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
70 public void ContinueOnCancelTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
71 var p = new Promise<bool>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
72 p.Cancel();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
73
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
74 var p2 = p
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
75 .Cancelled(() => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
76 throw new ApplicationException("CANCELLED");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
77 })
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
78 .Error(e => true);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
79
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
80 Assert.AreEqual(true, p2.Join());
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
81 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
82
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
83 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
84 public void JoinSuccessTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
85 var p = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
86 p.Resolve(100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
87 Assert.AreEqual(p.Join(), 100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
88 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
89
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
90 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
91 public void JoinFailTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
92 var p = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
93 p.Reject(new ApplicationException("failed"));
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
94
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
95 try {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
96 p.Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
97 throw new ApplicationException("WRONG!");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
98 } catch (TargetInvocationException err) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
99 Assert.AreEqual(err.InnerException.Message, "failed");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
100 } catch {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
101 Assert.Fail("Got wrong excaption");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
102 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
103 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
104
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
105 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
106 public void MapTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
107 var p = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
108
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
109 var p2 = p.Then(x => x.ToString());
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
110 p.Resolve(100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
111
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
112 Assert.AreEqual(p2.Join(), "100");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
113 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
114
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
115 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
116 public void FixErrorTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
117 var p = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
118
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
119 var p2 = p.Error(e => 101);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
120
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
121 p.Reject(new Exception());
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
122
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
123 Assert.AreEqual(p2.Join(), 101);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
124 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
125
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
126 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
127 public void ChainTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
128 var p1 = new Promise<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
129
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
130 var p3 = p1.Chain(x => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
131 var p2 = new Promise<string>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
132 p2.Resolve(x.ToString());
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
133 return p2;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
134 });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
135
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
136 p1.Resolve(100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
137
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
138 Assert.AreEqual(p3.Join(), "100");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
139 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
140
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
141 [TestMethod]
105
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
142 public void ChainFailTest() {
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
143 var p1 = new Promise<int>();
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
144
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
145 var p3 = p1.Chain(x => {
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
146 var p2 = new Promise<string>();
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
147 p2.Reject(new Exception("DIE!!!"));
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
148 return p2;
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
149 });
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
150
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
151 p1.Resolve(100);
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
152
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
153 Assert.IsTrue(p3.IsResolved);
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
154 }
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
155
4d308952fd5e minor fixes
cin
parents: 81
diff changeset
156 [TestMethod]
77
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
157 public void PoolTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
158 var pid = Thread.CurrentThread.ManagedThreadId;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
159 var p = AsyncPool.Invoke(() => Thread.CurrentThread.ManagedThreadId);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
160
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
161 Assert.AreNotEqual(pid, p.Join());
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
162 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
163
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
164 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
165 public void WorkerPoolSizeTest() {
81
2c5631b43c7d dispatch pool rewritten
cin
parents: 80
diff changeset
166 var pool = new WorkerPool(5, 10, 1);
77
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
167
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
168 Assert.AreEqual(5, pool.PoolSize);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
169
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
170 pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
171 pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
172 pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
173
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
174 Assert.AreEqual(5, pool.PoolSize);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
175
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
176 for (int i = 0; i < 100; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
177 pool.Invoke(() => { Thread.Sleep(100000000); return 10; });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
178 Thread.Sleep(200);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
179 Assert.AreEqual(10, pool.PoolSize);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
180
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
181 pool.Dispose();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
182 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
183
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
184 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
185 public void WorkerPoolCorrectTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
186 var pool = new WorkerPool(0,1000,100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
187
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
188 const int iterations = 1000;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
189 int pending = iterations;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
190 var stop = new ManualResetEvent(false);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
191
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
192 var count = 0;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
193 for (int i = 0; i < iterations; i++) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
194 pool
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
195 .Invoke(() => 1)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
196 .Then(x => Interlocked.Add(ref count, x))
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
197 .Then(x => Math.Log10(x))
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
198 .Anyway(() => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
199 Interlocked.Decrement(ref pending);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
200 if (pending == 0)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
201 stop.Set();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
202 });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
203 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
204
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
205 stop.WaitOne();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
206
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
207 Assert.AreEqual(iterations, count);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
208 Console.WriteLine("Max threads: {0}", pool.MaxRunningThreads);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
209 pool.Dispose();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
210
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
211 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
212
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
213 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
214 public void WorkerPoolDisposeTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
215 var pool = new WorkerPool(5, 20);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
216 Assert.AreEqual(5, pool.PoolSize);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
217 pool.Dispose();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
218 Thread.Sleep(500);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
219 Assert.AreEqual(0, pool.PoolSize);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
220 pool.Dispose();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
221 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
222
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
223 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
224 public void MTQueueTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
225 var queue = new MTQueue<int>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
226 int res;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
227
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
228 queue.Enqueue(10);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
229 Assert.IsTrue(queue.TryDequeue(out res));
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
230 Assert.AreEqual(10, res);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
231 Assert.IsFalse(queue.TryDequeue(out res));
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
232
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
233 for (int i = 0; i < 1000; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
234 queue.Enqueue(i);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
235
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
236 for (int i = 0; i < 1000; i++) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
237 queue.TryDequeue(out res);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
238 Assert.AreEqual(i, res);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
239 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
240
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
241 int writers = 0;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
242 int readers = 0;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
243 var stop = new ManualResetEvent(false);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
244 int total = 0;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
245
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
246 const int itemsPerWriter = 10000;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
247 const int writersCount = 10;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
248
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
249 for (int i = 0; i < writersCount; i++) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
250 Interlocked.Increment(ref writers);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
251 AsyncPool
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
252 .InvokeNewThread(() => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
253 for (int ii = 0; ii < itemsPerWriter; ii++) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
254 queue.Enqueue(1);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
255 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
256 return 1;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
257 })
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
258 .Anyway(() => Interlocked.Decrement(ref writers));
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
259 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
260
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
261 for (int i = 0; i < 10; i++) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
262 Interlocked.Increment(ref readers);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
263 AsyncPool
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
264 .InvokeNewThread(() => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
265 int t;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
266 do {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
267 while (queue.TryDequeue(out t))
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
268 Interlocked.Add(ref total, t);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
269 } while (writers > 0);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
270 return 1;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
271 })
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
272 .Anyway(() => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
273 Interlocked.Decrement(ref readers);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
274 if (readers == 0)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
275 stop.Set();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
276 });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
277 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
278
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
279 stop.WaitOne();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
280
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
281 Assert.AreEqual(itemsPerWriter * writersCount, total);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
282 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
283
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
284 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
285 public void ParallelMapTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
286
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
287 const int count = 100000;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
288
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
289 var args = new double[count];
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
290 var rand = new Random();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
291
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
292 for (int i = 0; i < count; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
293 args[i] = rand.NextDouble();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
294
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
295 var t = Environment.TickCount;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
296 var res = args.ParallelMap(x => Math.Sin(x*x), 4).Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
297
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
298 Console.WriteLine("Map complete in {0} ms", Environment.TickCount - t);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
299
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
300 t = Environment.TickCount;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
301 for (int i = 0; i < count; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
302 Assert.AreEqual(Math.Sin(args[i] * args[i]), res[i]);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
303 Console.WriteLine("Verified in {0} ms", Environment.TickCount - t);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
304 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
305
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
306 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
307 public void ChainedMapTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
308
81
2c5631b43c7d dispatch pool rewritten
cin
parents: 80
diff changeset
309 using (var pool = new WorkerPool(0,10,1)) {
77
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
310 const int count = 10000;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
311
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
312 var args = new double[count];
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
313 var rand = new Random();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
314
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
315 for (int i = 0; i < count; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
316 args[i] = rand.NextDouble();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
317
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
318 var t = Environment.TickCount;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
319 var res = args
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
320 .ChainedMap(
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
321 // Analysis disable once AccessToDisposedClosure
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
322 x => pool.Invoke(
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
323 () => Math.Sin(x * x)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
324 ),
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
325 4
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
326 )
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
327 .Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
328
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
329 Console.WriteLine("Map complete in {0} ms", Environment.TickCount - t);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
330
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
331 t = Environment.TickCount;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
332 for (int i = 0; i < count; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
333 Assert.AreEqual(Math.Sin(args[i] * args[i]), res[i]);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
334 Console.WriteLine("Verified in {0} ms", Environment.TickCount - t);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
335 Console.WriteLine("Max workers: {0}", pool.MaxRunningThreads);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
336 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
337 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
338
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
339 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
340 public void ParallelForEachTest() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
341
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
342 const int count = 100000;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
343
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
344 var args = new int[count];
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
345 var rand = new Random();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
346
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
347 for (int i = 0; i < count; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
348 args[i] = (int)(rand.NextDouble() * 100);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
349
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
350 int result = 0;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
351
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
352 var t = Environment.TickCount;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
353 args.ParallelForEach(x => Interlocked.Add(ref result, x), 4).Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
354
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
355 Console.WriteLine("Iteration complete in {0} ms, result: {1}", Environment.TickCount - t, result);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
356
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
357 int result2 = 0;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
358
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
359 t = Environment.TickCount;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
360 for (int i = 0; i < count; i++)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
361 result2 += args[i];
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
362 Assert.AreEqual(result2, result);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
363 Console.WriteLine("Verified in {0} ms", Environment.TickCount - t);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
364 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
365
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
366 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
367 public void ComplexCase1Test() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
368 var flags = new bool[3];
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
369
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
370 // op1 (aync 200ms) => op2 (async 200ms) => op3 (sync map)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
371
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
372 var step1 = PromiseHelper
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
373 .Sleep(200, "Alan")
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
374 .Cancelled(() => flags[0] = true);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
375 var p = step1
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
376 .Chain(x =>
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
377 PromiseHelper
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
378 .Sleep(200, "Hi, " + x)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
379 .Then(y => y)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
380 .Cancelled(() => flags[1] = true)
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
381 )
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
382 .Cancelled(() => flags[2] = true);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
383 step1.Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
384 p.Cancel();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
385 try {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
386 Assert.AreEqual(p.Join(), "Hi, Alan");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
387 Assert.Fail("Shouldn't get here");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
388 } catch (OperationCanceledException) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
389 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
390
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
391 Assert.IsFalse(flags[0]);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
392 Assert.IsTrue(flags[1]);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
393 Assert.IsTrue(flags[2]);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
394 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
395
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
396 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
397 public void ChainedCancel1Test() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
398 // при отмене сцепленной асинхронной операции все обещание должно
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
399 // завершаться ошибкой OperationCanceledException
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
400 var p = PromiseHelper
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
401 .Sleep(1, "Hi, HAL!")
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
402 .Then(x => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
403 // запускаем две асинхронные операции
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
404 var result = PromiseHelper.Sleep(1000, "HEM ENABLED!!!");
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
405 // вторая операция отменяет первую до завершения
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
406 PromiseHelper
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
407 .Sleep(100, "HAL, STOP!")
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
408 .Then(result.Cancel);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
409 return result;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
410 });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
411 try {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
412 p.Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
413 } catch (TargetInvocationException err) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
414 Assert.IsTrue(err.InnerException is OperationCanceledException);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
415 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
416 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
417
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
418 [TestMethod]
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
419 public void ChainedCancel2Test() {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
420 // при отмене цепочки обещаний, вложенные операции также должны отменяться
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
421 var pSurvive = new Promise<bool>();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
422 var hemStarted = new ManualResetEvent(false);
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
423 var p = PromiseHelper
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
424 .Sleep(1, "Hi, HAL!")
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
425 .Chain(x => {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
426 hemStarted.Set();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
427 // запускаем две асинхронные операции
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
428 var result = PromiseHelper
106
d4e38929ce36 promises refactoring
cin
parents: 105
diff changeset
429 .Sleep(100000000, "HEM ENABLED!!!")
d4e38929ce36 promises refactoring
cin
parents: 105
diff changeset
430 .Then(s => {
d4e38929ce36 promises refactoring
cin
parents: 105
diff changeset
431 pSurvive.Resolve(false);
d4e38929ce36 promises refactoring
cin
parents: 105
diff changeset
432 return s;
d4e38929ce36 promises refactoring
cin
parents: 105
diff changeset
433 });
77
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
434
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
435 result
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
436 .Cancelled(() => pSurvive.Resolve(true));
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
437
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
438 return result;
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
439 });
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
440
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
441 hemStarted.WaitOne();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
442 p.Cancel();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
443
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
444 try {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
445 p.Join();
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
446 } catch (OperationCanceledException) {
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
447 Assert.IsTrue(pSurvive.Join());
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
448 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
449 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
450 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
451 }
91362ffbecf8 ported tests to mono
cin
parents: 76
diff changeset
452