# | Line 340 | Line 340 | public class ScheduledExecutor extends T | |
---|---|---|
340 | if (getPoolSize() < getCorePoolSize()) | |
341 | prestartCoreThread(); | |
342 | ||
343 | < | super.getQueue().offer(command); |
343 | > | super.getQueue().add(command); |
344 | } | |
345 | ||
346 | /** | |
# | Line 639 | Line 639 | public class ScheduledExecutor extends T | |
639 | (!isShutdown() || | |
640 | (getContinueExistingPeriodicTasksAfterShutdownPolicy() && | |
641 | !isTerminating()))) | |
642 | < | super.getQueue().offer(next); |
642 | > | super.getQueue().add(next); |
643 | ||
644 | // This might have been the final executed delayed task. Wake | |
645 | // up threads to check. |
– | Removed lines |
+ | Added lines |
< | Changed lines |
> | Changed lines |