ViewVC Help
View File | Revision Log | Show Annotations | Download File | Root Listing
root/jsr166/jsr166/src/test/tck/PriorityQueueTest.java
(Generate patch)

Comparing jsr166/src/test/tck/PriorityQueueTest.java (file contents):
Revision 1.5 by dl, Sat Sep 20 18:20:08 2003 UTC vs.
Revision 1.38 by jsr166, Sun Oct 16 20:44:18 2016 UTC

# Line 1 | Line 1
1   /*
2 < * Written by members of JCP JSR-166 Expert Group and released to the
3 < * public domain. Use, modify, and redistribute this code in any way
4 < * without acknowledgement. Other contributors include Andrew Wright,
5 < * Jeffrey Hayes, Pat Fischer, Mike Judd.
2 > * Written by Doug Lea with assistance from members of JCP JSR-166
3 > * Expert Group and released to the public domain, as explained at
4 > * http://creativecommons.org/publicdomain/zero/1.0/
5 > * Other contributors include Andrew Wright, Jeffrey Hayes,
6 > * Pat Fisher, Mike Judd.
7   */
8  
9 < import junit.framework.*;
10 < import java.util.*;
11 < import java.util.concurrent.*;
12 < import java.io.*;
9 > import java.util.Arrays;
10 > import java.util.Collection;
11 > import java.util.Comparator;
12 > import java.util.Iterator;
13 > import java.util.NoSuchElementException;
14 > import java.util.PriorityQueue;
15 > import java.util.Queue;
16  
17 < public class PriorityQueueTest extends JSR166TestCase {
17 > import junit.framework.Test;
18 > import junit.framework.TestSuite;
19  
20 + public class PriorityQueueTest extends JSR166TestCase {
21      public static void main(String[] args) {
22 <        junit.textui.TestRunner.run (suite());  
22 >        main(suite(), args);
23      }
18
24      public static Test suite() {
25 <        return new TestSuite(PriorityQueueTest.class);
25 >        return new TestSuite(PriorityQueueTest.class);
26      }
27  
28 <    static class MyReverseComparator implements Comparator {
28 >    static class MyReverseComparator implements Comparator {
29          public int compare(Object x, Object y) {
30 <            int i = ((Integer)x).intValue();
26 <            int j = ((Integer)y).intValue();
27 <            if (i < j) return 1;
28 <            if (i > j) return -1;
29 <            return 0;
30 >            return ((Comparable)y).compareTo(x);
31          }
32      }
33  
33
34      /**
35 <     * Create a queue of given size containing consecutive
36 <     * Integers 0 ... n.
35 >     * Returns a new queue of given size containing consecutive
36 >     * Integers 0 ... n - 1.
37       */
38 <    private PriorityQueue populatedQueue(int n) {
39 <        PriorityQueue q = new PriorityQueue(n);
38 >    private PriorityQueue<Integer> populatedQueue(int n) {
39 >        PriorityQueue<Integer> q = new PriorityQueue<Integer>(n);
40          assertTrue(q.isEmpty());
41 <        for(int i = n-1; i >= 0; i-=2)
42 <            assertTrue(q.offer(new Integer(i)));
43 <        for(int i = (n & 1); i < n; i+=2)
44 <            assertTrue(q.offer(new Integer(i)));
41 >        for (int i = n - 1; i >= 0; i -= 2)
42 >            assertTrue(q.offer(new Integer(i)));
43 >        for (int i = (n & 1); i < n; i += 2)
44 >            assertTrue(q.offer(new Integer(i)));
45          assertFalse(q.isEmpty());
46 <        assertEquals(n, q.size());
46 >        assertEquals(n, q.size());
47 >        assertEquals((Integer) 0, q.peek());
48          return q;
49      }
50 <
50 >
51      /**
52 <     *
52 >     * A new queue has unbounded capacity
53       */
54      public void testConstructor1() {
55          assertEquals(0, new PriorityQueue(SIZE).size());
56      }
57  
58      /**
59 <     *
59 >     * Constructor throws IAE if capacity argument nonpositive
60       */
61      public void testConstructor2() {
62          try {
63 <            PriorityQueue q = new PriorityQueue(0);
63 >            new PriorityQueue(0);
64              shouldThrow();
65 <        }
65 <        catch (IllegalArgumentException success) {}
65 >        } catch (IllegalArgumentException success) {}
66      }
67  
68      /**
69 <     *
69 >     * Initializing from null Collection throws NPE
70       */
71      public void testConstructor3() {
72
72          try {
73 <            PriorityQueue q = new PriorityQueue((Collection)null);
73 >            new PriorityQueue((Collection)null);
74              shouldThrow();
75 <        }
77 <        catch (NullPointerException success) {}
75 >        } catch (NullPointerException success) {}
76      }
77  
78      /**
79 <     *
79 >     * Initializing from Collection of null elements throws NPE
80       */
81      public void testConstructor4() {
82          try {
83 <            Integer[] ints = new Integer[SIZE];
86 <            PriorityQueue q = new PriorityQueue(Arrays.asList(ints));
83 >            new PriorityQueue(Arrays.asList(new Integer[SIZE]));
84              shouldThrow();
85 <        }
89 <        catch (NullPointerException success) {}
85 >        } catch (NullPointerException success) {}
86      }
87  
88      /**
89 <     *
89 >     * Initializing from Collection with some null elements throws NPE
90       */
91      public void testConstructor5() {
92 +        Integer[] ints = new Integer[SIZE];
93 +        for (int i = 0; i < SIZE - 1; ++i)
94 +            ints[i] = new Integer(i);
95          try {
96 <            Integer[] ints = new Integer[SIZE];
98 <            for (int i = 0; i < SIZE-1; ++i)
99 <                ints[i] = new Integer(i);
100 <            PriorityQueue q = new PriorityQueue(Arrays.asList(ints));
96 >            new PriorityQueue(Arrays.asList(ints));
97              shouldThrow();
98 <        }
103 <        catch (NullPointerException success) {}
98 >        } catch (NullPointerException success) {}
99      }
100  
101      /**
102 <     *
102 >     * Queue contains all elements of collection used to initialize
103       */
104      public void testConstructor6() {
105 <        try {
106 <            Integer[] ints = new Integer[SIZE];
107 <            for (int i = 0; i < SIZE; ++i)
108 <                ints[i] = new Integer(i);
109 <            PriorityQueue q = new PriorityQueue(Arrays.asList(ints));
110 <            for (int i = 0; i < SIZE; ++i)
116 <                assertEquals(ints[i], q.poll());
117 <        }
118 <        finally {}
105 >        Integer[] ints = new Integer[SIZE];
106 >        for (int i = 0; i < SIZE; ++i)
107 >            ints[i] = new Integer(i);
108 >        PriorityQueue q = new PriorityQueue(Arrays.asList(ints));
109 >        for (int i = 0; i < SIZE; ++i)
110 >            assertEquals(ints[i], q.poll());
111      }
112  
113      /**
114 <     *
114 >     * The comparator used in constructor is used
115       */
116      public void testConstructor7() {
117 <        try {
118 <            MyReverseComparator cmp = new MyReverseComparator();
119 <            PriorityQueue q = new PriorityQueue(SIZE, cmp);
120 <            assertEquals(cmp, q.comparator());
121 <            Integer[] ints = new Integer[SIZE];
122 <            for (int i = 0; i < SIZE; ++i)
123 <                ints[i] = new Integer(i);
124 <            q.addAll(Arrays.asList(ints));
125 <            for (int i = SIZE-1; i >= 0; --i)
134 <                assertEquals(ints[i], q.poll());
135 <        }
136 <        finally {}
117 >        MyReverseComparator cmp = new MyReverseComparator();
118 >        PriorityQueue q = new PriorityQueue(SIZE, cmp);
119 >        assertEquals(cmp, q.comparator());
120 >        Integer[] ints = new Integer[SIZE];
121 >        for (int i = 0; i < SIZE; ++i)
122 >            ints[i] = new Integer(i);
123 >        q.addAll(Arrays.asList(ints));
124 >        for (int i = SIZE - 1; i >= 0; --i)
125 >            assertEquals(ints[i], q.poll());
126      }
127  
128      /**
129 <     *
129 >     * isEmpty is true before add, false after
130       */
131      public void testEmpty() {
132          PriorityQueue q = new PriorityQueue(2);
# Line 151 | Line 140 | public class PriorityQueueTest extends J
140      }
141  
142      /**
143 <     *
143 >     * size changes when elements added and removed
144       */
145      public void testSize() {
146          PriorityQueue q = populatedQueue(SIZE);
147          for (int i = 0; i < SIZE; ++i) {
148 <            assertEquals(SIZE-i, q.size());
148 >            assertEquals(SIZE - i, q.size());
149              q.remove();
150          }
151          for (int i = 0; i < SIZE; ++i) {
# Line 166 | Line 155 | public class PriorityQueueTest extends J
155      }
156  
157      /**
158 <     *
158 >     * offer(null) throws NPE
159       */
160      public void testOfferNull() {
161 <        try {
162 <            PriorityQueue q = new PriorityQueue(1);
161 >        PriorityQueue q = new PriorityQueue(1);
162 >        try {
163              q.offer(null);
164              shouldThrow();
165 <        } catch (NullPointerException success) { }  
165 >        } catch (NullPointerException success) {}
166      }
167  
168      /**
169 <     *
169 >     * add(null) throws NPE
170 >     */
171 >    public void testAddNull() {
172 >        PriorityQueue q = new PriorityQueue(1);
173 >        try {
174 >            q.add(null);
175 >            shouldThrow();
176 >        } catch (NullPointerException success) {}
177 >    }
178 >
179 >    /**
180 >     * Offer of comparable element succeeds
181       */
182      public void testOffer() {
183          PriorityQueue q = new PriorityQueue(1);
184 <        assertTrue(q.offer(new Integer(0)));
185 <        assertTrue(q.offer(new Integer(1)));
184 >        assertTrue(q.offer(zero));
185 >        assertTrue(q.offer(one));
186      }
187  
188      /**
189 <     *
189 >     * Offer of non-Comparable throws CCE
190       */
191      public void testOfferNonComparable() {
192 +        PriorityQueue q = new PriorityQueue(1);
193          try {
193            PriorityQueue q = new PriorityQueue(1);
194            q.offer(new Object());
195            q.offer(new Object());
194              q.offer(new Object());
195              shouldThrow();
196 +        } catch (ClassCastException success) {
197 +            assertTrue(q.isEmpty());
198 +            assertEquals(0, q.size());
199 +            assertNull(q.poll());
200          }
199        catch(ClassCastException success) {}
201      }
202  
203      /**
204 <     *
204 >     * add of comparable succeeds
205       */
206      public void testAdd() {
207          PriorityQueue q = new PriorityQueue(SIZE);
# Line 211 | Line 212 | public class PriorityQueueTest extends J
212      }
213  
214      /**
215 <     *
215 >     * addAll(null) throws NPE
216       */
217      public void testAddAll1() {
218 +        PriorityQueue q = new PriorityQueue(1);
219          try {
218            PriorityQueue q = new PriorityQueue(1);
220              q.addAll(null);
221              shouldThrow();
222 <        }
222 <        catch (NullPointerException success) {}
222 >        } catch (NullPointerException success) {}
223      }
224 +
225      /**
226 <     *
226 >     * addAll of a collection with null elements throws NPE
227       */
228      public void testAddAll2() {
229 +        PriorityQueue q = new PriorityQueue(SIZE);
230          try {
231 <            PriorityQueue q = new PriorityQueue(SIZE);
230 <            Integer[] ints = new Integer[SIZE];
231 <            q.addAll(Arrays.asList(ints));
231 >            q.addAll(Arrays.asList(new Integer[SIZE]));
232              shouldThrow();
233 <        }
234 <        catch (NullPointerException success) {}
233 >        } catch (NullPointerException success) {}
234      }
235 +
236      /**
237 <     *
237 >     * addAll of a collection with any null elements throws NPE after
238 >     * possibly adding some elements
239       */
240      public void testAddAll3() {
241 +        PriorityQueue q = new PriorityQueue(SIZE);
242 +        Integer[] ints = new Integer[SIZE];
243 +        for (int i = 0; i < SIZE - 1; ++i)
244 +            ints[i] = new Integer(i);
245          try {
241            PriorityQueue q = new PriorityQueue(SIZE);
242            Integer[] ints = new Integer[SIZE];
243            for (int i = 0; i < SIZE-1; ++i)
244                ints[i] = new Integer(i);
246              q.addAll(Arrays.asList(ints));
247              shouldThrow();
248 <        }
248 <        catch (NullPointerException success) {}
248 >        } catch (NullPointerException success) {}
249      }
250  
251      /**
252 <     *
252 >     * Queue contains all elements of successful addAll
253       */
254      public void testAddAll5() {
255 <        try {
256 <            Integer[] empty = new Integer[0];
257 <            Integer[] ints = new Integer[SIZE];
258 <            for (int i = 0; i < SIZE; ++i)
259 <                ints[i] = new Integer(SIZE-1-i);
260 <            PriorityQueue q = new PriorityQueue(SIZE);
261 <            assertFalse(q.addAll(Arrays.asList(empty)));
262 <            assertTrue(q.addAll(Arrays.asList(ints)));
263 <            for (int i = 0; i < SIZE; ++i)
264 <                assertEquals(new Integer(i), q.poll());
265 <        }
266 <        finally {}
255 >        Integer[] empty = new Integer[0];
256 >        Integer[] ints = new Integer[SIZE];
257 >        for (int i = 0; i < SIZE; ++i)
258 >            ints[i] = new Integer(SIZE - 1 - i);
259 >        PriorityQueue q = new PriorityQueue(SIZE);
260 >        assertFalse(q.addAll(Arrays.asList(empty)));
261 >        assertTrue(q.addAll(Arrays.asList(ints)));
262 >        for (int i = 0; i < SIZE; ++i)
263 >            assertEquals(new Integer(i), q.poll());
264      }
265  
266      /**
267 <     *
267 >     * poll succeeds unless empty
268       */
269      public void testPoll() {
270          PriorityQueue q = populatedQueue(SIZE);
271          for (int i = 0; i < SIZE; ++i) {
272 <            assertEquals(i, ((Integer)q.poll()).intValue());
272 >            assertEquals(i, q.poll());
273          }
274 <        assertNull(q.poll());
274 >        assertNull(q.poll());
275      }
276  
277      /**
278 <     *
278 >     * peek returns next element, or null if empty
279       */
280      public void testPeek() {
281          PriorityQueue q = populatedQueue(SIZE);
282          for (int i = 0; i < SIZE; ++i) {
283 <            assertEquals(i, ((Integer)q.peek()).intValue());
284 <            q.poll();
283 >            assertEquals(i, q.peek());
284 >            assertEquals(i, q.poll());
285              assertTrue(q.peek() == null ||
286 <                       i != ((Integer)q.peek()).intValue());
286 >                       !q.peek().equals(i));
287          }
288 <        assertNull(q.peek());
288 >        assertNull(q.peek());
289      }
290  
291      /**
292 <     *
292 >     * element returns next element, or throws NSEE if empty
293       */
294      public void testElement() {
295          PriorityQueue q = populatedQueue(SIZE);
296          for (int i = 0; i < SIZE; ++i) {
297 <            assertEquals(i, ((Integer)q.element()).intValue());
298 <            q.poll();
297 >            assertEquals(i, q.element());
298 >            assertEquals(i, q.poll());
299          }
300          try {
301              q.element();
302              shouldThrow();
303 <        }
307 <        catch (NoSuchElementException success) {}
303 >        } catch (NoSuchElementException success) {}
304      }
305  
306      /**
307 <     *
307 >     * remove removes next element, or throws NSEE if empty
308       */
309      public void testRemove() {
310          PriorityQueue q = populatedQueue(SIZE);
311          for (int i = 0; i < SIZE; ++i) {
312 <            assertEquals(i, ((Integer)q.remove()).intValue());
312 >            assertEquals(i, q.remove());
313          }
314          try {
315              q.remove();
316              shouldThrow();
317 <        } catch (NoSuchElementException success){
322 <        }  
317 >        } catch (NoSuchElementException success) {}
318      }
319  
320      /**
321 <     *
321 >     * remove(x) removes x and returns true if present
322       */
323      public void testRemoveElement() {
324          PriorityQueue q = populatedQueue(SIZE);
325 <        for (int i = 1; i < SIZE; i+=2) {
326 <            assertTrue(q.remove(new Integer(i)));
327 <        }
328 <        for (int i = 0; i < SIZE; i+=2) {
329 <            assertTrue(q.remove(new Integer(i)));
330 <            assertFalse(q.remove(new Integer(i+1)));
325 >        for (int i = 1; i < SIZE; i += 2) {
326 >            assertTrue(q.contains(i));
327 >            assertTrue(q.remove(i));
328 >            assertFalse(q.contains(i));
329 >            assertTrue(q.contains(i - 1));
330 >        }
331 >        for (int i = 0; i < SIZE; i += 2) {
332 >            assertTrue(q.contains(i));
333 >            assertTrue(q.remove(i));
334 >            assertFalse(q.contains(i));
335 >            assertFalse(q.remove(i + 1));
336 >            assertFalse(q.contains(i + 1));
337          }
338          assertTrue(q.isEmpty());
339      }
340 <        
340 >
341      /**
342 <     *
342 >     * contains(x) reports true when elements added but not yet removed
343       */
344      public void testContains() {
345          PriorityQueue q = populatedQueue(SIZE);
# Line 350 | Line 351 | public class PriorityQueueTest extends J
351      }
352  
353      /**
354 <     *
354 >     * clear removes all elements
355       */
356      public void testClear() {
357          PriorityQueue q = populatedQueue(SIZE);
# Line 364 | Line 365 | public class PriorityQueueTest extends J
365      }
366  
367      /**
368 <     *
368 >     * containsAll(c) is true when c contains a subset of elements
369       */
370      public void testContainsAll() {
371          PriorityQueue q = populatedQueue(SIZE);
# Line 378 | Line 379 | public class PriorityQueueTest extends J
379      }
380  
381      /**
382 <     *
382 >     * retainAll(c) retains only those elements of c and reports true if changed
383       */
384      public void testRetainAll() {
385          PriorityQueue q = populatedQueue(SIZE);
# Line 391 | Line 392 | public class PriorityQueueTest extends J
392                  assertTrue(changed);
393  
394              assertTrue(q.containsAll(p));
395 <            assertEquals(SIZE-i, q.size());
395 >            assertEquals(SIZE - i, q.size());
396              p.remove();
397          }
398      }
399  
400      /**
401 <     *
401 >     * removeAll(c) removes only those elements of c and reports true if changed
402       */
403      public void testRemoveAll() {
404          for (int i = 1; i < SIZE; ++i) {
405              PriorityQueue q = populatedQueue(SIZE);
406              PriorityQueue p = populatedQueue(i);
407              assertTrue(q.removeAll(p));
408 <            assertEquals(SIZE-i, q.size());
408 >            assertEquals(SIZE - i, q.size());
409              for (int j = 0; j < i; ++j) {
410 <                Integer I = (Integer)(p.remove());
411 <                assertFalse(q.contains(I));
410 >                Integer x = (Integer)(p.remove());
411 >                assertFalse(q.contains(x));
412              }
413          }
414      }
415  
416      /**
417 <     *
417 >     * toArray contains all elements
418       */
419      public void testToArray() {
420          PriorityQueue q = populatedQueue(SIZE);
421 <        Object[] o = q.toArray();
421 >        Object[] o = q.toArray();
422          Arrays.sort(o);
423 <        for(int i = 0; i < o.length; i++)
424 <            assertEquals(o[i], q.poll());
423 >        for (int i = 0; i < o.length; i++)
424 >            assertSame(o[i], q.poll());
425      }
426  
427      /**
428 <     *
428 >     * toArray(a) contains all elements
429       */
430      public void testToArray2() {
431 <        PriorityQueue q = populatedQueue(SIZE);
432 <        Integer[] ints = new Integer[SIZE];
433 <        ints = (Integer[])q.toArray(ints);
431 >        PriorityQueue<Integer> q = populatedQueue(SIZE);
432 >        Integer[] ints = new Integer[SIZE];
433 >        Integer[] array = q.toArray(ints);
434 >        assertSame(ints, array);
435          Arrays.sort(ints);
436 <        for(int i = 0; i < ints.length; i++)
437 <            assertEquals(ints[i], q.poll());
436 >        for (int i = 0; i < ints.length; i++)
437 >            assertSame(ints[i], q.poll());
438      }
439 <    
439 >
440      /**
441 <     *
441 >     * iterator iterates through all elements
442       */
443      public void testIterator() {
444          PriorityQueue q = populatedQueue(SIZE);
445 <        int i = 0;
446 <        Iterator it = q.iterator();
447 <        while(it.hasNext()) {
445 >        Iterator it = q.iterator();
446 >        int i;
447 >        for (i = 0; it.hasNext(); i++)
448              assertTrue(q.contains(it.next()));
447            ++i;
448        }
449          assertEquals(i, SIZE);
450 +        assertIteratorExhausted(it);
451 +    }
452 +
453 +    /**
454 +     * iterator of empty collection has no elements
455 +     */
456 +    public void testEmptyIterator() {
457 +        assertIteratorExhausted(new PriorityQueue().iterator());
458      }
459  
460      /**
461 <     *
461 >     * iterator.remove removes current element
462       */
463 <    public void testIteratorRemove () {
463 >    public void testIteratorRemove() {
464          final PriorityQueue q = new PriorityQueue(3);
465          q.add(new Integer(2));
466          q.add(new Integer(1));
# Line 468 | Line 476 | public class PriorityQueueTest extends J
476          assertFalse(it.hasNext());
477      }
478  
471
479      /**
480 <     *
480 >     * toString contains toStrings of elements
481       */
482      public void testToString() {
483          PriorityQueue q = populatedQueue(SIZE);
484          String s = q.toString();
485          for (int i = 0; i < SIZE; ++i) {
486 <            assertTrue(s.indexOf(String.valueOf(i)) >= 0);
486 >            assertTrue(s.contains(String.valueOf(i)));
487          }
488 <    }        
488 >    }
489  
490      /**
491 <     *
491 >     * A deserialized serialized queue has same elements
492       */
493 <    public void testSerialization() {
494 <        PriorityQueue q = populatedQueue(SIZE);
495 <        try {
489 <            ByteArrayOutputStream bout = new ByteArrayOutputStream(10000);
490 <            ObjectOutputStream out = new ObjectOutputStream(new BufferedOutputStream(bout));
491 <            out.writeObject(q);
492 <            out.close();
493 >    public void testSerialization() throws Exception {
494 >        Queue x = populatedQueue(SIZE);
495 >        Queue y = serialClone(x);
496  
497 <            ByteArrayInputStream bin = new ByteArrayInputStream(bout.toByteArray());
498 <            ObjectInputStream in = new ObjectInputStream(new BufferedInputStream(bin));
499 <            PriorityQueue r = (PriorityQueue)in.readObject();
500 <            assertEquals(q.size(), r.size());
501 <            while (!q.isEmpty())
499 <                assertEquals(q.remove(), r.remove());
500 <        } catch(Exception e){
501 <            unexpectedException();
497 >        assertNotSame(x, y);
498 >        assertEquals(x.size(), y.size());
499 >        while (!x.isEmpty()) {
500 >            assertFalse(y.isEmpty());
501 >            assertEquals(x.remove(), y.remove());
502          }
503 +        assertTrue(y.isEmpty());
504      }
505   }

Diff Legend

Removed lines
+ Added lines
< Changed lines
> Changed lines