Searched refs:getQueue (Results 1 – 6 of 6) sorted by relevance
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 ScheduledThreadPoolExecutor841 return super.getQueue(); in getQueue()
1758 public BlockingQueue<Runnable> getQueue() { in getQueue() method in ThreadPoolExecutor2126 e.getQueue().poll(); in rejectedExecution()
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()
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()
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()
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()