*/
package org.opendaylight.yangtools.util.concurrent;
-import static org.junit.Assert.assertEquals;
-import static org.junit.Assert.assertFalse;
-import static org.junit.Assert.assertThrows;
-import static org.junit.Assert.assertTrue;
+import static org.junit.jupiter.api.Assertions.assertEquals;
+import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertThrows;
+import static org.junit.jupiter.api.Assertions.assertTrue;
import java.util.Arrays;
import java.util.concurrent.TimeUnit;
-import org.junit.Test;
+import org.junit.jupiter.api.Test;
/**
* Unit tests for TrackingLinkedBlockingQueue.
*
* @author Thomas Pantelis
*/
-public class TrackingLinkedBlockingQueueTest {
+class TrackingLinkedBlockingQueueTest {
@Test
- public void testOffer() throws InterruptedException {
- TrackingLinkedBlockingQueue<String> queue = new TrackingLinkedBlockingQueue<>(2);
+ void testOffer() throws InterruptedException {
+ final var queue = new TrackingLinkedBlockingQueue<>(2);
- assertTrue("offer", queue.offer("1"));
- assertEquals("getLargestQueueSize", 1, queue.getLargestQueueSize());
- assertEquals("size", 1, queue.size());
+ assertTrue(queue.offer("1"), "offer");
+ assertEquals(1, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(1, queue.size(), "size");
- assertTrue("offer", queue.offer("2", 1, TimeUnit.MILLISECONDS));
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertTrue(queue.offer("2", 1, TimeUnit.MILLISECONDS), "offer");
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
- assertFalse("offer", queue.offer("3"));
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertFalse(queue.offer("3"), "offer");
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
- assertFalse("offer", queue.offer("4", 1, TimeUnit.MILLISECONDS));
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertFalse(queue.offer("4", 1, TimeUnit.MILLISECONDS), "offer");
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
}
@Test
- public void testPut() throws InterruptedException {
- TrackingLinkedBlockingQueue<String> queue = new TrackingLinkedBlockingQueue<>();
+ void testPut() throws InterruptedException {
+ final var queue = new TrackingLinkedBlockingQueue<>();
queue.put("1");
- assertEquals("getLargestQueueSize", 1, queue.getLargestQueueSize());
- assertEquals("size", 1, queue.size());
+ assertEquals(1, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(1, queue.size(), "size");
queue.put("2");
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
}
@Test
- public void testAdd() {
- TrackingLinkedBlockingQueue<String> queue = new TrackingLinkedBlockingQueue<>(2);
+ void testAdd() {
+ final var queue = new TrackingLinkedBlockingQueue<>(2);
- assertTrue("add", queue.add("1"));
- assertEquals("getLargestQueueSize", 1, queue.getLargestQueueSize());
- assertEquals("size", 1, queue.size());
+ assertTrue(queue.add("1"), "add");
+ assertEquals(1, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(1, queue.size(), "size");
- assertTrue("add", queue.add("2"));
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertTrue(queue.add("2"), "add");
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
assertThrows(IllegalStateException.class, () -> queue.add("3"));
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
}
@Test
- public void testAddAll() {
- TrackingLinkedBlockingQueue<String> queue = new TrackingLinkedBlockingQueue<>(3);
+ void testAddAll() {
+ final var queue = new TrackingLinkedBlockingQueue<>(3);
queue.addAll(Arrays.asList("1", "2"));
- assertEquals("getLargestQueueSize", 2, queue.getLargestQueueSize());
- assertEquals("size", 2, queue.size());
+ assertEquals(2, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(2, queue.size(), "size");
assertThrows(IllegalStateException.class, () -> queue.addAll(Arrays.asList("3", "4")));
- assertEquals("getLargestQueueSize", 3, queue.getLargestQueueSize());
- assertEquals("size", 3, queue.size());
+ assertEquals(3, queue.getLargestQueueSize(), "getLargestQueueSize");
+ assertEquals(3, queue.size(), "size");
}
}