| /libcore/ojluni/src/main/java/java/util/concurrent/ |
| D | ScheduledThreadPoolExecutor.java | 347 super.getQueue().add(task); in delayedExecute()
363 super.getQueue().add(task); in reExecutePeriodic()
377 BlockingQueue<Runnable> q = super.getQueue(); in onShutdown()
547 Delayed head = (Delayed) super.getQueue().peek(); in overflowFree()
896 public BlockingQueue<Runnable> getQueue() { in getQueue() method in ScheduledThreadPoolExecutor
897 return super.getQueue(); in getQueue()
|
| D | ThreadPoolExecutor.java | 1757 public BlockingQueue<Runnable> getQueue() { in getQueue() method in ThreadPoolExecutor
2141 e.getQueue().poll(); in rejectedExecution()
|
| /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 | 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()
|
| 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()
|
| /libcore/ojluni/src/test/java/util/concurrent/tck/ |
| D | ScheduledExecutorSubclassTest.java | 673 BlockingQueue<Runnable> q = p.getQueue(); in testGetQueue()
697 BlockingQueue<Runnable> q = p.getQueue(); in testRemove()
768 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
790 assertEquals(new HashSet(tasks), new HashSet(p.getQueue())); in testShutdownNow_delayedTasks()
798 assertTrue(p.getQueue().isEmpty()); in testShutdownNow_delayedTasks()
866 assertTrue(p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
867 assertTrue(p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
881 p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
883 p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
|
| D | ScheduledExecutorTest.java | 620 BlockingQueue<Runnable> q = p.getQueue(); in testGetQueue()
644 BlockingQueue<Runnable> q = p.getQueue(); in testRemove()
716 assertTrue(p.getQueue().isEmpty()); in testShutdownNow()
738 assertEquals(new HashSet(tasks), new HashSet(p.getQueue())); in testShutdownNow_delayedTasks()
746 assertTrue(p.getQueue().isEmpty()); in testShutdownNow_delayedTasks()
814 assertTrue(p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
815 assertTrue(p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
829 p.getQueue().containsAll(periodics)); in testShutdown_cancellation()
831 p.getQueue().containsAll(delayeds)); in testShutdown_cancellation()
|
| 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()
|
| 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()
|
| /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 | 16388 method public java.util.concurrent.BlockingQueue<java.lang.Runnable> getQueue();
|