pub/ImplabNet: Implab.Test/AsyncTests.cs comparison

comparison Implab.Test/AsyncTests.cs @ 77:91362ffbecf8 v2

ported tests to mono

author	cin
date	Thu, 11 Sep 2014 10:56:14 +0400
parents	c761fc982e1d
children	4f20870d0816

comparison

equal deleted inserted replaced

-:c761fc982e1d
+:91362ffbecf8
 using System;
-using Microsoft.VisualStudio.TestTools.UnitTesting;
 using System.Reflection;
 using System.Threading;
 using Implab.Parallels;
+#if MONO
+using NUnit.Framework;
+using TestClassAttribute = NUnit.Framework.TestFixtureAttribute;
+using TestMethod = NUnit.Framework.TestAttribute;
+#else
+using Microsoft.VisualStudio.TestTools.UnitTesting;
+#endif
 namespace Implab.Test {
 [TestClass]
 public class AsyncTests {
 [TestMethod]
 [TestMethod]
 public void WorkerPoolCorrectTest() {
 var pool = new WorkerPool(0,1000,100);
-int iterations = 1000;
+const int iterations = 1000;
 int pending = iterations;
 var stop = new ManualResetEvent(false);
 var count = 0;
 for (int i = 0; i < iterations; i++) {
 int writers = 0;
 int readers = 0;
 var stop = new ManualResetEvent(false);
 int total = 0;
-int itemsPerWriter = 10000;
+const int itemsPerWriter = 10000;
-int writersCount = 10;
+const int writersCount = 10;
 for (int i = 0; i < writersCount; i++) {
 Interlocked.Increment(ref writers);
-var wn = i;
 AsyncPool
 .InvokeNewThread(() => {
 for (int ii = 0; ii < itemsPerWriter; ii++) {
 queue.Enqueue(1);
 }
 .Anyway(() => Interlocked.Decrement(ref writers));
 }
 for (int i = 0; i < 10; i++) {
 Interlocked.Increment(ref readers);
-var wn = i;
 AsyncPool
 .InvokeNewThread(() => {
 int t;
 do {
 while (queue.TryDequeue(out t))
 }
 [TestMethod]
 public void ParallelMapTest() {
-int count = 100000;
+const int count = 100000;
-double[] args = new double[count];
+var args = new double[count];
 var rand = new Random();
 for (int i = 0; i < count; i++)
 args[i] = rand.NextDouble();
 [TestMethod]
 public void ChainedMapTest() {
 using (var pool = new WorkerPool(0,100,100)) {
-int count = 10000;
+const int count = 10000;
-double[] args = new double[count];
+var args = new double[count];
 var rand = new Random();
 for (int i = 0; i < count; i++)
 args[i] = rand.NextDouble();
 var t = Environment.TickCount;
 var res = args
 .ChainedMap(
+// Analysis disable once AccessToDisposedClosure
 x => pool.Invoke(
 () => Math.Sin(x * x)
 ),
 4
 )
 }
 [TestMethod]
 public void ParallelForEachTest() {
-int count = 100000;
+const int count = 100000;
-int[] args = new int[count];
+var args = new int[count];
 var rand = new Random();
 for (int i = 0; i < count; i++)
 args[i] = (int)(rand.NextDouble() * 100);
 public void ComplexCase1Test() {
 var flags = new bool[3];
 // op1 (aync 200ms) => op2 (async 200ms) => op3 (sync map)
-var p = PromiseHelper
+var step1 = PromiseHelper
 .Sleep(200, "Alan")
-.Cancelled(() => flags[0] = true)
+.Cancelled(() => flags[0] = true);
+var p = step1
 .Chain(x =>
 PromiseHelper
 .Sleep(200, "Hi, " + x)
 .Then(y => y)
 .Cancelled(() => flags[1] = true)
 )
 .Cancelled(() => flags[2] = true);
-Thread.Sleep(300);
+step1.Join();
 p.Cancel();
 try {
 Assert.AreEqual(p.Join(), "Hi, Alan");
 Assert.Fail("Shouldn't get here");
 } catch (OperationCanceledException) {
 Assert.IsTrue(flags[2]);
 }
 [TestMethod]
 public void ChainedCancel1Test() {
-// ��� ������ ���������� ����������� �������� ��� �������� ������
+// при отмене сцепленной асинхронной операции все обещание должно
-// ����������� ������� OperationCanceledException
+// завершаться ошибкой OperationCanceledException
 var p = PromiseHelper
 .Sleep(1, "Hi, HAL!")
 .Then(x => {
-// ��������� ��� ����������� ��������
+// запускаем две асинхронные операции
 var result = PromiseHelper.Sleep(1000, "HEM ENABLED!!!");
-// ������ �������� �������� ������ �� ����������
+// вторая операция отменяет первую до завершения
 PromiseHelper
 .Sleep(100, "HAL, STOP!")
-.Then(() => result.Cancel());
+.Then(result.Cancel);
 return result;
 });
 try {
 p.Join();
 } catch (TargetInvocationException err) {
 }
 }
 [TestMethod]
 public void ChainedCancel2Test() {
-// ��� ������ ������� ��������, ��������� �������� ����� ������ ����������
+// при отмене цепочки обещаний, вложенные операции также должны отменяться
 var pSurvive = new Promise<bool>();
 var hemStarted = new ManualResetEvent(false);
 var p = PromiseHelper
 .Sleep(1, "Hi, HAL!")
 .Chain(x => {
 hemStarted.Set();
-// ��������� ��� ����������� ��������
+// запускаем две асинхронные операции
 var result = PromiseHelper
 .Sleep(10000, "HEM ENABLED!!!")
 .Then(s => pSurvive.Resolve(false));
 result

Mercurial > pub > ImplabNet

comparison Implab.Test/AsyncTests.cs @ 77:91362ffbecf8 v2