Searched refs:ListeningExecutorService (Results 1 – 11 of 11) sorted by relevance
31 extends ForwardingExecutorService implements ListeningExecutorService {36 protected abstract ListeningExecutorService delegate(); in delegate()
269 @Deprecated public static ListeningExecutorService sameThreadExecutor() { in sameThreadExecutor()429 public static ListeningExecutorService newDirectExecutorService() { in newDirectExecutorService()479 public static ListeningExecutorService listeningDecorator( in listeningDecorator()481 return (delegate instanceof ListeningExecutorService) in listeningDecorator()482 ? (ListeningExecutorService) delegate in listeningDecorator()672 */ static <T> T invokeAnyImpl(ListeningExecutorService executorService, in invokeAnyImpl()746 ListeningExecutorService executorService, Callable<T> task, in submitAndAddQueueListener()
36 extends ScheduledExecutorService, ListeningExecutorService {
35 public interface ListeningExecutorService extends ExecutorService { interface
39 extends AbstractExecutorService implements ListeningExecutorService {
91 final ListeningExecutorService executor = newDirectExecutorService(); in testDirectExecutorServiceServiceInThreadExecution()263 ListeningExecutorService executor = newDirectExecutorService(); in testListeningExecutorServiceInvokeAllJavadocCodeCompiles()270 ListeningExecutorService service = in testListeningDecorator()291 ListeningExecutorService service = listeningDecorator(delegate); in testListeningDecorator_noWrapExecuteTask()419 ListeningExecutorService e = newDirectExecutorService(); in testInvokeAnyImpl_nullTasks()433 ListeningExecutorService e = newDirectExecutorService(); in testInvokeAnyImpl_emptyTasks()447 ListeningExecutorService e = newDirectExecutorService(); in testInvokeAnyImpl_nullElement()468 ListeningExecutorService e = newDirectExecutorService(); in testInvokeAnyImpl_noTaskCompletes()485 ListeningExecutorService e = newDirectExecutorService(); in testInvokeAnyImpl()
36 import com.google.common.util.concurrent.ListeningExecutorService;75 private final Provider<ListeningExecutorService> executorProvider;86 Provider<ListeningExecutorService> executorProvider) { in ExperimentingCaliperRun()155 final ListeningExecutorService executor = executorProvider.get(); in run()206 final ListeningExecutorService executor) { in scheduleTrials()
35 import com.google.common.util.concurrent.ListeningExecutorService;84 static ListeningExecutorService provideExecutorService(CaliperConfig config) { in provideExecutorService()
33 import com.google.common.util.concurrent.ListeningExecutorService;88 private final ListeningExecutorService streamExecutor = MoreExecutors.listeningDecorator(
5 import com.google.common.util.concurrent.ListeningExecutorService;31 ListeningExecutorService executorService = MoreExecutors.newDirectExecutorService(); in setUpComponent()
25 import com.google.common.util.concurrent.ListeningExecutorService;51 private final ListeningExecutorService delegate = newDirectExecutorService();