Lines Matching refs:executor
60 * @param executor the executor to modify to make sure it exits when the
62 * @param terminationTimeout how long to wait for the executor to
69 ThreadPoolExecutor executor, long terminationTimeout, TimeUnit timeUnit) {
70 executor.setThreadFactory(new ThreadFactoryBuilder()
72 .setThreadFactory(executor.getThreadFactory())
75 ExecutorService service = Executors.unconfigurableExecutorService(executor);
91 * @param executor the executor to modify to make sure it exits when the
93 * @param terminationTimeout how long to wait for the executor to
100 ScheduledThreadPoolExecutor executor, long terminationTimeout,
102 executor.setThreadFactory(new ThreadFactoryBuilder()
104 .setThreadFactory(executor.getThreadFactory())
108 Executors.unconfigurableScheduledExecutorService(executor);
122 * @param terminationTimeout how long to wait for the executor to finish
154 * even if the executor has not finished its work.
159 * @param executor the executor to modify to make sure it exits when the
165 ThreadPoolExecutor executor) {
166 return getExitingExecutorService(executor, 120, TimeUnit.SECONDS);
175 * even if the executor has not finished its work.
180 * @param executor the executor to modify to make sure it exits when the
186 ScheduledThreadPoolExecutor executor) {
187 return getExitingScheduledExecutorService(executor, 120, TimeUnit.SECONDS);
191 * Creates an executor service that runs each task in the thread
197 * executor has been shutdown).
232 * (runningTasks, shutdown, terminationCondition) of the executor
236 /** Signaled after the executor is shutdown and running tasks are done */
240 * Conceptually, these two variables describe the executor being in
317 * Checks if the executor has been shut down and increments the running
320 * @throws RejectedExecutionException if the executor has been previously
354 * given delegate executor. Those methods, as well as {@code execute} and
363 * <p>If the delegate executor was already an instance of {@code
381 * given delegate executor. Those methods, as well as {@code execute} and
391 * <p>If the delegate executor was already an instance of {@code