{
baseEnumerable = Enumerable.Range(1, 1000);
}
-
- void AreEquivalent (IEnumerable<int> syncEnumerable, IEnumerable<int> async_resEnumerable, int count)
- {
- int[] sync = Enumerable.ToArray(syncEnumerable);
- int[] async_res = Enumerable.ToArray(async_resEnumerable);
-
- // This is not AreEquals because ParallelQuery is non-deterministic (IParallelOrderedEnumerable is)
- // thus the order of the initial Enumerable might not be preserved
- string error = "";
-
- if (sync.Length != async_res.Length)
- error = string.Format ("Expected size {0} but got {1} #{2}", sync.Length, async_res.Length, count);
-
- Array.Sort (sync);
- Array.Sort (async_res);
- int i, j;
- for (i = j = 0; i < sync.Length && j < async_res.Length; ++i) {
- if (sync [i] != async_res [j])
- error += "missing " + sync [i] + "";
- else
- ++j;
- }
- if (error != "")
- Assert.Fail (error);
- }
-
- void AreEquivalent<T> (IEnumerable<T> syncEnumerable, IEnumerable<T> async_resEnumerable, int count)
+
+ static void AreEquivalent (IEnumerable syncEnumerable, IEnumerable async_resEnumerable)
{
- T[] sync = Enumerable.ToArray(syncEnumerable);
- T[] async_res = Enumerable.ToArray(async_resEnumerable);
-
- // This is not AreEquals because ParallelQuery is non-deterministic (IParallelOrderedEnumerable is)
- // thus the order of the initial Enumerable might not be preserved
- CollectionAssert.AreEquivalent(sync, async_res, "#" + count);
+ Assert.That (async_resEnumerable, new NUnit.Framework.Constraints.CollectionEquivalentConstraint (syncEnumerable));
}
static void AssertAreSame<T> (IEnumerable<T> expected, IEnumerable<T> actual)
IEnumerable<int> sync = baseEnumerable.Select (i => i * i);
IEnumerable<int> async_res = baseEnumerable.AsParallel ().Select (i => i * i);
- AreEquivalent(sync, async_res, 1);
+ AreEquivalent(sync, async_res);
});
}
IEnumerable<int> sync = baseEnumerable.Where(i => i % 2 == 0);
IEnumerable<int> async_res = baseEnumerable.AsParallel().Where(i => i % 2 == 0);
- AreEquivalent(sync, async_res, 1);
+ AreEquivalent(sync, async_res);
});
}
int [] second = {2, 4, 6};
int [] result = {0, 1, 3, 5};
- AreEquivalent (result, first.AsReallyParallel ().Except (second.AsParallel ()), 1);
+ AreEquivalent (result, first.AsReallyParallel ().Except (second.AsParallel ()));
});
}
int [] second = {2, 4, 6};
int [] result = {2, 4};
- AreEquivalent (result, first.AsReallyParallel ().Intersect (second.AsParallel ()), 1);
+ AreEquivalent (result, first.AsReallyParallel ().Intersect (second.AsParallel ()));
});
}
int [] second = {2, 4, 6};
int [] result = {0, 1, 2, 3, 4, 5, 6};
- AreEquivalent (result, first.AsReallyParallel ().Union (second.AsParallel ()), 1);
+ AreEquivalent (result, first.AsReallyParallel ().Union (second.AsParallel ()));
});
}
int [] first = Enumerable.Range (1, 10000).ToArray ();
int [] second = Enumerable.Range (323, 757).ToArray ();
- AreEquivalent (first, first.AsReallyParallel ().Union (second.AsParallel ()), 1);
- }, 10);
+ var expected = first;
+ var actual = first.AsReallyParallel ().Union (second.AsParallel ()).ToArray ();
+ // Work around quadratic behavior in NUnitLite's CollectionTally class
+ Array.Sort (expected);
+ Array.Sort (actual);
+ AreEquivalent (expected, actual);
+ });
}
[Test]
int [] first = Enumerable.Range (1, 10000).ToArray ();
int [] second = Enumerable.Range (323, 757).ToArray ();
- AreEquivalent (second, first.AsReallyParallel ().Intersect (second.AsParallel ()), 1);
- }, 10);
+ AreEquivalent (second, first.AsReallyParallel ().Intersect (second.AsParallel ()));
+ });
}
class Foo {}
Foo [] foos = new Foo [] {a, b, c};
Bar [] result = new Bar [] {a, b, c};
- AreEquivalent (result, foos.AsReallyParallel ().Cast<Bar> (), 1);
+ AreEquivalent (result, foos.AsReallyParallel ().Cast<Bar> ());
}
[Test]
int [] data = {0, 1, 2, 3, 4, 5};
int [] result = {3, 4, 5};
- AssertAreSame (result, data.AsReallyParallel ().AsOrdered ().Skip (3).ToArray ());
+ AssertAreSame (result, data.AsParallel ().AsOrdered ().Skip (3).ToArray ());
}
[Test]
int [] data = {0, 1, 2, 3, 4, 5};
int [] result = {3, 4, 5};
- AssertAreSame (result, data.AsReallyParallel ().AsOrdered ().Skip (3));
+ AssertAreSame (result, data.AsParallel ().AsOrdered ().Skip (3));
}
[Test]
int [] data = {0, 1, 2, 3, 4, 5};
int [] result = {3, 4, 5};
- AssertAreSame (result, data.AsReallyParallel ().AsOrdered ().SkipWhile (i => i < 3));
+ AssertAreSame (result, data.AsParallel ().AsOrdered ().SkipWhile (i => i < 3));
}
[Test]
int [] data = {0, 1, 2, 3, 4, 5};
int [] result = {0, 1, 2};
- AssertAreSame (result, data.AsReallyParallel ().AsOrdered ().Take (3));
+ AssertAreSame (result, data.AsParallel ().AsOrdered ().Take (3));
}
[Test]
int [] data = {0, 1, 2, 3, 4, 5};
int [] result = {0, 1, 2};
- AssertAreSame (result, data.AsReallyParallel ().AsOrdered ().TakeWhile (i => i < 3));
+ AssertAreSame (result, data.AsParallel ().AsOrdered ().TakeWhile (i => i < 3));
}
[Test]
ParallelTestHelper.Repeat (() => {
var actual = initial.AsReallyParallel ().SelectMany ((i) => Enumerable.Range (1, i));
- AreEquivalent (expected, actual, 1);
+ AreEquivalent (expected, actual);
});
}
IEnumerable<int> expected = initial.SelectMany ((i) => Enumerable.Range (1, i));
ParallelTestHelper.Repeat (() => {
- var actual = initial.AsReallyParallel ().AsOrdered ().SelectMany ((i) => Enumerable.Range (1, i));
+ var actual = initial.AsParallel ().AsOrdered ().SelectMany ((i) => Enumerable.Range (1, i));
AssertAreSame (expected, actual);
});
}
{
int [] data = {1, 2, 3};
- Assert.AreEqual (3, data.AsReallyParallel ().AsOrdered ().Last ());
+ Assert.AreEqual (3, data.AsParallel ().AsOrdered ().Last ());
}
[Test]
{
int [] data = {};
- Assert.AreEqual (default (int), data.AsReallyParallel ().AsOrdered ().LastOrDefault ());
+ Assert.AreEqual (default (int), data.AsParallel ().AsOrdered ().LastOrDefault ());
}
[Test]
{
int [] data = {1, 2, 3};
- Assert.AreEqual (1, data.AsReallyParallel ().AsOrdered ().First ());
+ Assert.AreEqual (1, data.AsParallel ().AsOrdered ().First ());
}
[Test]
{
int [] data = {};
- Assert.AreEqual (default (int), data.AsReallyParallel ().AsOrdered ().FirstOrDefault ());
+ Assert.AreEqual (default (int), data.AsParallel ().AsOrdered ().FirstOrDefault ());
}
[Test]
int [] data = {0, 1, 2, 3, 4};
int [] result = {4, 3, 2, 1, 0};
- AssertAreSame (result, ((IEnumerable<int>)data).Select ((i) => i).AsReallyParallel ().AsOrdered ().Reverse ());
- AssertAreSame (result, ParallelEnumerable.Range (0, 5).AsReallyParallel ().AsOrdered ().Reverse ());
+ AssertAreSame (result, ((IEnumerable<int>)data).Select ((i) => i).AsParallel ().AsOrdered ().Reverse ());
+ AssertAreSame (result, ParallelEnumerable.Range (0, 5).AsParallel ().AsOrdered ().Reverse ());
}
[Test]
public void ElementAtTestCase()
{
//ParallelTestHelper.Repeat (() => {
- Assert.AreEqual(1, baseEnumerable.AsReallyParallel ().AsOrdered ().ElementAt(0), "#1");
- Assert.AreEqual(51, baseEnumerable.AsReallyParallel ().AsOrdered ().ElementAt(50), "#2");
- Assert.AreEqual(489, baseEnumerable.AsReallyParallel ().AsOrdered ().ElementAt(488), "#3");
+ Assert.AreEqual(1, baseEnumerable.AsParallel ().AsOrdered ().ElementAt(0), "#1");
+ Assert.AreEqual(51, baseEnumerable.AsParallel ().AsOrdered ().ElementAt(50), "#2");
+ Assert.AreEqual(489, baseEnumerable.AsParallel ().AsOrdered ().ElementAt(488), "#3");
//});
}
(e) => e.Item1,
(e1, e2) => e1.Item2 + e2.Item2,
EqualityComparer<int>.Default);
- AreEquivalent (expected, actual, 1);
+ AreEquivalent (expected, actual);
});
}
{
var items = new [] { 1, 2, 3 };
var items2 = new [] { 1, 2, 3, 4 };
- var actual = items.AsReallyParallel ().Join (items2.AsReallyParallel (), i => i, i => i, (e1, e2) => e1 + e2);
- AreEquivalent (new[] { 2, 4, 6 }, actual, 1);
+ var actual = items.AsReallyParallel ().Join (items2.AsParallel (), i => i, i => i, (e1, e2) => e1 + e2);
+ AreEquivalent (new[] { 2, 4, 6 }, actual);
}
[Test]
- [Category ("NotWorking")] // Deadlocks randomly
public void TestGroupBy ()
{
int num = 100;
ParallelTestHelper.Repeat (() => {
ParallelQuery<IGrouping<int, int>> actual = source.AsReallyParallel ().GroupBy ((e) => e.Item1, (e) => e.Item2, EqualityComparer<int>.Default);
foreach (var group in actual) {
- Assert.GreaterOrEqual (group.Key, 0);
- Assert.Less (group.Key, num / 10);
+ Assert.IsTrue (group.Key >= 0);
+ Assert.IsTrue (group.Key < num / 10);
int count = 0;
foreach (var e in group) {
count++;
- Assert.GreaterOrEqual (e, group.Key * 10);
- Assert.Less (e, (group.Key + 1) * 10);
+ Assert.IsTrue (e >= group.Key * 10);
+ Assert.IsTrue (e < (group.Key + 1) * 10);
}
Assert.AreEqual (10, count, "count");
public void TakeTestCase()
{
ParallelTestHelper.Repeat (() => {
- ParallelQuery<int> async_res = baseEnumerable.AsReallyParallel ().AsOrdered ().Take(800);
+ ParallelQuery<int> async_res = baseEnumerable.AsParallel ().AsOrdered ().Take(800);
IEnumerable<int> sync = baseEnumerable.Take(800);
- AreEquivalent(sync, async_res, 1);
+ AreEquivalent(sync, async_res);
- async_res = baseEnumerable.AsReallyParallel ().AsOrdered ().Take(100);
+ async_res = baseEnumerable.AsParallel ().AsOrdered ().Take(100);
sync = baseEnumerable.Take(100);
- AreEquivalent(sync, async_res, 2);
+ AreEquivalent(sync, async_res);
});
}
public void SkipTestCase()
{
ParallelTestHelper.Repeat (() => {
- ParallelQuery<int> async_res = baseEnumerable.AsReallyParallel ().AsOrdered().Skip (800);
+ ParallelQuery<int> async_res = baseEnumerable.AsParallel ().AsOrdered().Skip (800);
IEnumerable<int> sync = baseEnumerable.Skip (800);
- AreEquivalent (sync, async_res, 1);
+ AreEquivalent (sync, async_res);
});
}
var sync = baseEnumerable.Skip(100);
Assert.AreEqual (sync.Count (), async_res.Count ());
- }, 20);
+ });
}
[Test]
ParallelTestHelper.Repeat (() => {
ParallelQuery<int> async_res1 = ParallelEnumerable.Range(0, 10000);
ParallelQuery<int> async_res2 = ParallelEnumerable.Repeat(1, 10000).Zip(async_res1, (e1, e2) => e1 + e2);
-
+
int[] expected = Enumerable.Range (1, 10000).ToArray ();
- CollectionAssert.AreEquivalent(expected, Enumerable.ToArray (async_res2), "#1");
+ var actual = Enumerable.ToArray (async_res2);
+ // Work around quadratic behavior in NUnitLite's CollectionTally class
+ Array.Sort (expected);
+ Array.Sort (actual);
+ AreEquivalent(expected, actual);
});
}
[Test]
- public void RangeTestCase ()
+ public void Range ()
{
ParallelTestHelper.Repeat (() => {
IEnumerable<int> sync = Enumerable.Range(1, 1000);
IEnumerable<int> async_res = ParallelEnumerable.Range(1, 1000);
- AreEquivalent (sync, async_res, 1);
+ AreEquivalent (sync, async_res);
});
}
-
+
+ [Test]
+ public void Range_StartOffset ()
+ {
+ ParallelTestHelper.Repeat (() => {
+ IEnumerable<int> sync = Enumerable.Range (30, 10);
+ IEnumerable<int> async_res = ParallelEnumerable.Range (30, 10);
+
+ AreEquivalent (sync, async_res);
+ });
+ }
+
[Test]
public void RepeatTestCase ()
{
IEnumerable<int> sync = Enumerable.Repeat(1, 1000);
IEnumerable<int> async_res = ParallelEnumerable.Repeat(1, 1000);
- AreEquivalent (sync, async_res, 1);
+ AreEquivalent (sync, async_res);
});
}
int [] result = {0, 1, 2};
- var array = coll.AsReallyParallel ().AsOrdered().ToArray ();
+ var array = coll.AsParallel ().AsOrdered().ToArray ();
AssertAreSame (result, array);
AssertIsOrdered (array, result.Length);
Assert.AreEqual (typeof (int []), array.GetType ());
- array = Enumerable.Range (1, 100).Select ((i) => i).AsReallyParallel ().AsOrdered().ToArray ();
+ array = Enumerable.Range (1, 100).Select ((i) => i).AsParallel ().AsOrdered().ToArray ();
result = Enumerable.Range (1, 100).ToArray ();
AssertAreSame (result, array);
var list = data.AsReallyParallel ().ToList ();
- CollectionAssert.AreEquivalent (data, list);
+ AreEquivalent (data, list);
Assert.AreEqual (typeof (List<int>), list.GetType ());
}
var array = coll.AsReallyParallel ().ToArray ();
- CollectionAssert.AreEquivalent (result, array);
+ AreEquivalent (result, array);
Assert.AreEqual (typeof (int []), array.GetType ());
}
var data2 = new int[] { 1, 2, 4 };
var data3 = new int[] { 1, 2, 3, 4 };
- Assert.IsTrue (data1.AsReallyParallel ().SequenceEqual (data1.AsReallyParallel ()));
- Assert.IsTrue (data2.AsReallyParallel ().SequenceEqual (data2.AsReallyParallel ()));
- Assert.IsTrue (data3.AsReallyParallel ().SequenceEqual (data3.AsReallyParallel ()));
- Assert.IsFalse (data1.AsReallyParallel ().SequenceEqual (data2.AsReallyParallel ()));
- Assert.IsFalse (data1.AsReallyParallel ().SequenceEqual (data3.AsReallyParallel ()));
- Assert.IsFalse (data2.AsReallyParallel ().SequenceEqual (data3.AsReallyParallel ()));
+ Assert.IsTrue (data1.AsParallel ().SequenceEqual (data1.AsParallel ()));
+ Assert.IsTrue (data2.AsParallel ().SequenceEqual (data2.AsParallel ()));
+ Assert.IsTrue (data3.AsParallel ().SequenceEqual (data3.AsParallel ()));
+ Assert.IsFalse (data1.AsParallel ().SequenceEqual (data2.AsParallel ()));
+ Assert.IsFalse (data1.AsParallel ().SequenceEqual (data3.AsParallel ()));
+ Assert.IsFalse (data2.AsParallel ().SequenceEqual (data3.AsParallel ()));
}
[Test]
projects / mono.git / blobdiff