Permalink
Browse files

Limit concurrency in tests which exposes MpscRelaxed issue

  • Loading branch information...
nitsanw committed Sep 28, 2017
1 parent 834cf71 commit b006bc9ee5d7725f0d5f327cb2b659e824f6c6ae
@@ -37,8 +37,8 @@ public MpqSanityTestMpscRelaxedArray(ConcurrentQueueSpec spec, MessagePassingQue
public static Collection<Object[]> parameters()
{
ArrayList<Object[]> list = new ArrayList<Object[]>();
list.add(makeMpq(0, 1, 2, Ordering.FIFO, new MpscRelaxedArrayQueue<>(2)));// MPSC size 2
list.add(makeMpq(0, 1, SIZE, Ordering.FIFO, new MpscRelaxedArrayQueue<>(SIZE)));// MPSC size SIZE
list.add(makeMpq(1, 1, 2, Ordering.FIFO, new MpscRelaxedArrayQueue<>(2)));// MPSC size 2
list.add(makeMpq(1, 1, SIZE, Ordering.FIFO, new MpscRelaxedArrayQueue<>(SIZE)));// MPSC size SIZE
return list;
}
}
@@ -36,8 +36,8 @@ public QueueSanityTestMpscRelaxed(ConcurrentQueueSpec spec, Queue<Integer> queue
public static Collection<Object[]> parameters()
{
ArrayList<Object[]> list = new ArrayList<Object[]>();
list.add(makeQueue(0, 1, 2, Ordering.FIFO, new MpscRelaxedArrayQueue<Integer>(2)));// MPSC size 1
list.add(makeQueue(0, 1, SIZE, Ordering.FIFO, new MpscRelaxedArrayQueue<Integer>(SIZE)));// MPSC size SIZE
list.add(makeQueue(1, 1, 2, Ordering.FIFO, new MpscRelaxedArrayQueue<Integer>(2)));// MPSC size 1
list.add(makeQueue(1, 1, SIZE, Ordering.FIFO, new MpscRelaxedArrayQueue<Integer>(SIZE)));// MPSC size SIZE
return list;
}

0 comments on commit b006bc9

Please sign in to comment.