Lines Matching refs:service
270 ListeningExecutorService service =
272 assertSame(service, listeningDecorator(service));
277 results = service.invokeAll(callables);
280 results = service.invokeAll(callables, 1, SECONDS);
291 ListeningExecutorService service = listeningDecorator(delegate);
296 service.execute(task);
308 ListeningScheduledExecutorService service = listeningDecorator(delegate);
310 service.schedule(Callables.returning(null), 1, TimeUnit.MILLISECONDS);
325 ListeningScheduledExecutorService service = listeningDecorator(delegate);
328 service.schedule(new ThrowingRunnable(0, ex), 1, TimeUnit.MILLISECONDS);
335 ListeningScheduledExecutorService service = listeningDecorator(delegate);
341 future = service.scheduleAtFixedRate(runnable, 1, 1, TimeUnit.MILLISECONDS);
347 future = service.scheduleWithFixedDelay(runnable, 1, 1, TimeUnit.MILLISECONDS);
356 ListeningScheduledExecutorService service = listeningDecorator(delegate);
364 future = service.schedule(runnable, 5, TimeUnit.MINUTES);
372 future = service.scheduleAtFixedRate(runnable, 5, 5, TimeUnit.MINUTES);
380 future = service.scheduleWithFixedDelay(runnable, 5, 5, TimeUnit.MINUTES);
514 ExecutorService service = mock(ExecutorService.class);
515 application.addDelayedShutdownHook(service, 2, TimeUnit.SECONDS);
516 verify(service, Mockito.never()).shutdown();
518 InOrder shutdownFirst = Mockito.inOrder(service);
519 shutdownFirst.verify(service).shutdown();
520 shutdownFirst.verify(service).awaitTermination(2, TimeUnit.SECONDS);
525 ExecutorService service = mock(ExecutorService.class);
526 application.addDelayedShutdownHook(service, 2, TimeUnit.SECONDS);
527 when(service.awaitTermination(2, TimeUnit.SECONDS)).thenThrow(new InterruptedException());
529 verify(service).shutdown();
633 ExecutorService service = Executors.newSingleThreadExecutor();
634 assertTrue(shutdownAndAwaitTermination(service, 1L, SECONDS));
635 assertTrue(service.isTerminated());
639 ExecutorService service = mock(ExecutorService.class);
640 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS)).thenReturn(true);
641 when(service.isTerminated()).thenReturn(true);
642 assertTrue(shutdownAndAwaitTermination(service, 1L, SECONDS));
643 verify(service).shutdown();
644 verify(service).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);
648 ExecutorService service = mock(ExecutorService.class);
649 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS))
651 when(service.isTerminated()).thenReturn(true);
652 assertTrue(shutdownAndAwaitTermination(service, 1L, SECONDS));
653 verify(service).shutdown();
654 verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);
655 verify(service).shutdownNow();
659 ExecutorService service = mock(ExecutorService.class);
660 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS))
662 assertFalse(shutdownAndAwaitTermination(service, 1L, SECONDS));
663 verify(service).shutdown();
664 verify(service, times(2)).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);
665 verify(service).shutdownNow();
669 final ExecutorService service = mock(ExecutorService.class);
670 when(service.awaitTermination(HALF_SECOND_NANOS, NANOSECONDS))
681 terminated.set(shutdownAndAwaitTermination(service, 1L, SECONDS));
687 verify(service).shutdown();
688 verify(service).awaitTermination(HALF_SECOND_NANOS, NANOSECONDS);
689 verify(service).shutdownNow();
