| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ScheduledThreadPoolExecutor.java | 336 super.getQueue().add(task); in delayedExecute()
354 super.getQueue().add(task); in reExecutePeriodic()
367 BlockingQueue<Runnable> q = super.getQueue(); in onShutdown()
540 Delayed head = (Delayed) super.getQueue().peek(); in overflowFree()
840 public BlockingQueue<Runnable> getQueue() { in getQueue() method in ScheduledThreadPoolExecutor
841 return super.getQueue(); in getQueue()
|
| D | ThreadPoolExecutor.java | 1764 public BlockingQueue<Runnable> getQueue() { in getQueue() method in ThreadPoolExecutor
2132 e.getQueue().poll(); in rejectedExecution()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ScheduledExecutorSubclassTest.java | 671 BlockingQueue<Runnable> q = p.getQueue(); in testGetQueue()
695 BlockingQueue<Runnable> q = p.getQueue(); in testRemove()
766 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
788 assertEquals(new HashSet(tasks), new HashSet(p.getQueue())); in testShutdownNow_delayedTasks()
796 assertTrue(p.getQueue().isEmpty()); in testShutdownNow_delayedTasks()
861 assertTrue(p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
862 assertTrue(p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
876 p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
878 p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
|
| D | ScheduledExecutorTest.java | 618 BlockingQueue<Runnable> q = p.getQueue(); in testGetQueue()
642 BlockingQueue<Runnable> q = p.getQueue(); in testRemove()
714 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
736 assertEquals(new HashSet(tasks), new HashSet(p.getQueue())); in testShutdownNow_delayedTasks()
744 assertTrue(p.getQueue().isEmpty()); in testShutdownNow_delayedTasks()
809 assertTrue(p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
810 assertTrue(p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
824 p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
826 p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
|
| D | ThreadPoolExecutorSubclassTest.java | 694 assertSame(q, p.getQueue()); in testGetQueue()
702 assertSame(q, p.getQueue()); in testGetQueue()
814 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
1257 assertTrue(p.getQueue().contains(r2)); in testSaturatedExecute4()
1259 assertFalse(p.getQueue().contains(r2)); in testSaturatedExecute4()
1260 assertTrue(p.getQueue().contains(r3)); in testSaturatedExecute4()
|
| D | ThreadPoolExecutorTest.java | 579 assertSame(q, p.getQueue()); in testGetQueue()
587 assertSame(q, p.getQueue()); in testGetQueue()
699 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
1228 assertTrue(p.getQueue().contains(r2)); in testSaturatedExecute4()
1230 assertFalse(p.getQueue().contains(r2)); in testSaturatedExecute4()
1231 assertTrue(p.getQueue().contains(r3)); in testSaturatedExecute4()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ScheduledExecutorSubclassTest.java | 649 BlockingQueue<Runnable> q = p.getQueue(); in testGetQueue()
673 BlockingQueue<Runnable> q = p.getQueue(); in testRemove()
744 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
766 assertEquals(new HashSet(tasks), new HashSet(p.getQueue())); in testShutdownNow_delayedTasks()
774 assertTrue(p.getQueue().isEmpty()); in testShutdownNow_delayedTasks()
839 assertTrue(p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
840 assertTrue(p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
854 p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
856 p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
|
| D | ScheduledExecutorTest.java | 597 BlockingQueue<Runnable> q = p.getQueue(); in testGetQueue()
621 BlockingQueue<Runnable> q = p.getQueue(); in testRemove()
693 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
715 assertEquals(new HashSet(tasks), new HashSet(p.getQueue())); in testShutdownNow_delayedTasks()
723 assertTrue(p.getQueue().isEmpty()); in testShutdownNow_delayedTasks()
788 assertTrue(p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
789 assertTrue(p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
803 p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
805 p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
|
| D | ThreadPoolExecutorSubclassTest.java | 672 assertSame(q, p.getQueue()); in testGetQueue()
680 assertSame(q, p.getQueue()); in testGetQueue()
792 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
1235 assertTrue(p.getQueue().contains(r2)); in testSaturatedExecute4()
1237 assertFalse(p.getQueue().contains(r2)); in testSaturatedExecute4()
1238 assertTrue(p.getQueue().contains(r3)); in testSaturatedExecute4()
|
| D | ThreadPoolExecutorTest.java | 557 assertSame(q, p.getQueue()); in testGetQueue()
565 assertSame(q, p.getQueue()); in testGetQueue()
677 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
1206 assertTrue(p.getQueue().contains(r2)); in testSaturatedExecute4()
1208 assertFalse(p.getQueue().contains(r2)); in testSaturatedExecute4()
1209 assertTrue(p.getQueue().contains(r3)); in testSaturatedExecute4()
|
| /libcore/ojluni/annotations/hiddenapi/java/util/concurrent/ |
| D | ThreadPoolExecutor.java | 273 public java.util.concurrent.BlockingQueue<java.lang.Runnable> getQueue() { in getQueue() method in ThreadPoolExecutor
|
| /libcore/api/ |
| D | current.txt | 15056 method public java.util.concurrent.BlockingQueue<java.lang.Runnable> getQueue();
|