1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18 package org.apache.hadoop.hbase.util;
19
20 import static org.junit.Assert.assertEquals;
21 import static org.junit.Assert.assertFalse;
22 import static org.junit.Assert.assertNull;
23 import static org.junit.Assert.assertTrue;
24
25 import org.apache.hadoop.hbase.testclassification.SmallTests;
26 import org.junit.Test;
27 import org.junit.experimental.categories.Category;
28
29 @Category(SmallTests.class)
30 public class TestBoundedArrayQueue {
31
32 private int qMaxElements = 5;
33 private BoundedArrayQueue<Integer> queue = new BoundedArrayQueue<Integer>(qMaxElements);
34
35 @Test
36 public void testBoundedArrayQueueOperations() throws Exception {
37 assertEquals(0, queue.size());
38 assertNull(queue.poll());
39 assertNull(queue.peek());
40 for(int i=0;i<qMaxElements;i++){
41 assertTrue(queue.offer(i));
42 }
43 assertEquals(qMaxElements, queue.size());
44 assertFalse(queue.offer(0));
45 assertEquals(0, queue.peek().intValue());
46 assertEquals(0, queue.peek().intValue());
47 for (int i = 0; i < qMaxElements; i++) {
48 assertEquals(i, queue.poll().intValue());
49 }
50 assertEquals(0, queue.size());
51 assertNull(queue.poll());
52
53 assertTrue(queue.offer(100));
54 assertTrue(queue.offer(1000));
55 assertEquals(100, queue.peek().intValue());
56 assertEquals(100, queue.poll().intValue());
57 assertEquals(1000, queue.poll().intValue());
58 }
59 }