--- jsr166/src/test/tck/LinkedTransferQueueTest.java 2021/01/26 13:33:06 1.86 +++ jsr166/src/test/tck/LinkedTransferQueueTest.java 2021/01/27 02:55:18 1.88 @@ -100,8 +100,7 @@ public class LinkedTransferQueueTest ext public void testConstructor5() { Item[] items = defaultItems; List intList = Arrays.asList(items); - LinkedTransferQueue q - = new LinkedTransferQueue(intList); + LinkedTransferQueue q = new LinkedTransferQueue<>(intList); mustEqual(q.size(), intList.size()); mustEqual(q.toString(), intList.toString()); assertTrue(Arrays.equals(q.toArray(), @@ -148,7 +147,7 @@ public class LinkedTransferQueueTest ext * NullPointerException after possibly adding some elements */ public void testAddAll3() { - LinkedTransferQueue q = new LinkedTransferQueue(); + LinkedTransferQueue q = new LinkedTransferQueue<>(); Item[] items = new Item[2]; items[0] = zero; try { q.addAll(Arrays.asList(items)); @@ -370,7 +369,7 @@ public class LinkedTransferQueueTest ext * An add following remove(x) succeeds */ public void testRemoveElementAndAdd() throws InterruptedException { - LinkedTransferQueue q = new LinkedTransferQueue(); + LinkedTransferQueue q = new LinkedTransferQueue<>(); mustAdd(q, one); mustAdd(q, two); mustRemove(q, one); @@ -485,7 +484,8 @@ public class LinkedTransferQueueTest ext /** * toArray(incompatible array type) throws ArrayStoreException */ - public void testToArray1_BadArg() { + @SuppressWarnings("CollectionToArraySafeParameter") + public void testToArray_incompatibleArrayType() { LinkedTransferQueue q = populatedQueue(SIZE); try { q.toArray(new String[10]); @@ -523,7 +523,7 @@ public class LinkedTransferQueueTest ext * iterator.remove() removes current element */ public void testIteratorRemove() { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); q.add(two); q.add(one); q.add(three); @@ -559,7 +559,7 @@ public class LinkedTransferQueueTest ext * Modifications do not cause iterators to fail */ public void testWeaklyConsistentIteration() { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); q.add(one); q.add(two); q.add(three); @@ -585,7 +585,7 @@ public class LinkedTransferQueueTest ext * offer transfers elements across Executor tasks */ public void testOfferInExecutor() { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); final CheckedBarrier threadsStarted = new CheckedBarrier(2); final ExecutorService executor = Executors.newFixedThreadPool(2); try (PoolCleaner cleaner = cleaner(executor)) { @@ -611,7 +611,7 @@ public class LinkedTransferQueueTest ext * timed poll retrieves elements across Executor threads */ public void testPollInExecutor() { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); final CheckedBarrier threadsStarted = new CheckedBarrier(2); final ExecutorService executor = Executors.newFixedThreadPool(2); try (PoolCleaner cleaner = cleaner(executor)) { @@ -700,7 +700,7 @@ public class LinkedTransferQueueTest ext * drainTo(c, n) empties first min(n, size) elements of queue into c */ public void testDrainToN() { - LinkedTransferQueue q = new LinkedTransferQueue(); + LinkedTransferQueue q = new LinkedTransferQueue<>(); for (int i = 0; i < SIZE + 2; ++i) { for (int j = 0; j < SIZE; j++) { mustOffer(q, j); @@ -721,7 +721,7 @@ public class LinkedTransferQueueTest ext * offer(e) decrements the waiting consumer count */ public void testWaitingConsumer() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); mustEqual(0, q.getWaitingConsumerCount()); assertFalse(q.hasWaitingConsumer()); final CountDownLatch threadStarted = new CountDownLatch(1); @@ -737,8 +737,8 @@ public class LinkedTransferQueueTest ext }}); threadStarted.await(); - Callable oneConsumer - = new Callable() { public Boolean call() { + Callable oneConsumer = new Callable<>() { + public Boolean call() { return q.hasWaitingConsumer() && q.getWaitingConsumerCount() == 1; }}; waitForThreadToEnterWaitState(t, oneConsumer); @@ -755,7 +755,7 @@ public class LinkedTransferQueueTest ext */ public void testTransfer1() throws InterruptedException { try { - LinkedTransferQueue q = new LinkedTransferQueue(); + LinkedTransferQueue q = new LinkedTransferQueue<>(); q.transfer(null); shouldThrow(); } catch (NullPointerException success) {} @@ -777,8 +777,8 @@ public class LinkedTransferQueueTest ext }}); threadStarted.await(); - Callable oneElement - = new Callable() { public Boolean call() { + Callable oneElement = new Callable<>() { + public Boolean call() { return !q.isEmpty() && q.size() == 1; }}; waitForThreadToEnterWaitState(t, oneElement); @@ -824,7 +824,7 @@ public class LinkedTransferQueueTest ext * thread returns the element */ public void testTransfer4() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); Thread t = newStartedThread(new CheckedRunnable() { public void realRun() throws InterruptedException { @@ -868,7 +868,7 @@ public class LinkedTransferQueueTest ext * tryTransfer(null) throws NullPointerException */ public void testTryTransfer1() { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); try { q.tryTransfer(null); shouldThrow(); @@ -880,7 +880,7 @@ public class LinkedTransferQueueTest ext * consumers waiting to poll or take. */ public void testTryTransfer2() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); assertFalse(q.tryTransfer(new Object())); assertFalse(q.hasWaitingConsumer()); checkEmpty(q); @@ -892,7 +892,7 @@ public class LinkedTransferQueueTest ext */ public void testTryTransfer3() throws InterruptedException { final Object hotPotato = new Object(); - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); Thread t = newStartedThread(new CheckedRunnable() { public void realRun() { @@ -916,7 +916,7 @@ public class LinkedTransferQueueTest ext */ public void testTryTransfer4() throws InterruptedException { final Object hotPotato = new Object(); - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); Thread t = newStartedThread(new CheckedRunnable() { public void realRun() { @@ -936,7 +936,7 @@ public class LinkedTransferQueueTest ext * tryTransfer blocks interruptibly if no takers */ public void testTryTransfer5() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); final CountDownLatch pleaseInterrupt = new CountDownLatch(1); assertTrue(q.isEmpty()); @@ -968,7 +968,7 @@ public class LinkedTransferQueueTest ext * tryTransfer gives up after the timeout and returns false */ public void testTryTransfer6() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); Thread t = newStartedThread(new CheckedRunnable() { public void realRun() throws InterruptedException { @@ -988,7 +988,7 @@ public class LinkedTransferQueueTest ext * before transfering to a poll or take */ public void testTryTransfer7() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); assertTrue(q.offer(four)); Thread t = newStartedThread(new CheckedRunnable() { @@ -1013,7 +1013,7 @@ public class LinkedTransferQueueTest ext * returning false not enqueueing and the successive poll is null */ public void testTryTransfer8() throws InterruptedException { - final LinkedTransferQueue q = new LinkedTransferQueue(); + final LinkedTransferQueue q = new LinkedTransferQueue<>(); assertTrue(q.offer(four)); mustEqual(1, q.size()); long startTime = System.nanoTime(); @@ -1042,7 +1042,7 @@ public class LinkedTransferQueueTest ext */ public void testNeverContainsNull() { Collection[] qs = { - new LinkedTransferQueue(), + new LinkedTransferQueue<>(), populatedQueue(2), };