/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | AbstractListeningExecutorService.java | 45 @Override protected final <T> ListenableFutureTask<T> newTaskFor(Callable<T> callable) { argument 46 return ListenableFutureTask.create(callable);
|
H A D | Callables.java | 49 * Wraps the given callable such that for the duration of {@link Callable#call} the thread that is 53 * @param callable The callable to wrap 55 * for each invocation of the wrapped callable. 57 static <T> Callable<T> threadRenaming(final Callable<T> callable, argument 60 checkNotNull(callable); 67 return callable.call(); 84 * for each invocation of the wrapped callable.
|
H A D | FakeTimeLimiter.java | 48 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration, argument 51 return callable.call(); // fooled you
|
H A D | ListenableFutureTask.java | 49 * @param callable the callable task 52 public static <V> ListenableFutureTask<V> create(Callable<V> callable) { argument 53 return new ListenableFutureTask<V>(callable); 73 ListenableFutureTask(Callable<V> callable) { argument 74 super(callable);
|
H A D | ListeningScheduledExecutorService.java | 46 Callable<V> callable, long delay, TimeUnit unit); 45 schedule( Callable<V> callable, long delay, TimeUnit unit) argument
|
H A D | TimeLimiter.java | 91 * @param callable the Callable to execute 104 <T> T callWithTimeout(Callable<T> callable, long timeoutDuration, argument
|
H A D | SimpleTimeLimiter.java | 100 Callable<Object> callable = new Callable<Object>() { 111 return callWithTimeout(callable, timeoutDuration, timeoutUnit, 120 public <T> T callWithTimeout(Callable<T> callable, long timeoutDuration, argument 122 checkNotNull(callable); 126 Future<T> future = executor.submit(callable);
|
H A D | WrappingExecutorService.java | 58 protected abstract <T> Callable<T> wrapTask(Callable<T> callable); argument 66 Executors.callable(command, null));
|
/external/junit/src/main/java/org/junit/rules/ |
H A D | ErrorCollector.java | 72 * Adds to the table the exception, if any, thrown from {@code callable}. 74 * {@code callable} threw an exception. 76 public <T> T checkSucceeds(Callable<T> callable) { argument 78 return callable.call();
|
/external/mockito/src/main/java/org/mockito/internal/invocation/ |
H A D | RealMethod.java | 36 public FromCallable(final Callable<?> callable) { argument 40 return callable.call();
|
/external/robolectric-shadows/utils/src/main/java/org/robolectric/util/ |
H A D | SimpleFuture.java | 18 private final Callable<T> callable; field in class:SimpleFuture 20 public SimpleFuture(Callable<T> callable) { argument 21 this.callable = callable; 58 result = callable.call();
|
/external/guava/guava-testlib/test/com/google/common/testing/ |
H A D | FakeTickerTest.java | 145 * Runs {@code callable} concurrently {@code numberOfThreads} times. 148 private void runConcurrentTest(int numberOfThreads, final Callable<Void> callable) argument 159 callable.call();
|
/external/webrtc/talk/app/webrtc/java/android/org/webrtc/ |
H A D | ThreadUtils.java | 157 * Post |callable| to |handler| and wait for the result. 159 public static <V> V invokeUninterruptibly(final Handler handler, final Callable<V> callable) { argument 168 result.value = callable.call();
|
/external/autotest/server/cros/dynamic_suite/ |
H A D | job_status_unittest.py | 129 def callable(x): function in function:StatusTest._prepareForReporting 132 record_entity = self.mox.CreateMock(callable)
|
/external/droiddriver/src/io/appium/droiddriver/util/ |
H A D | InstrumentationUtils.java | 135 * Runs {@code callable} on the main thread on best-effort basis up to a time limit, which 141 * am command line.The {@code callable} may never run, for example, if the main Looper has exited 144 public static <V> V runOnMainSyncWithTimeout(Callable<V> callable) { argument 146 final RunOnMainSyncFutureTask<V> futureTask = new RunOnMainSyncFutureTask<>(callable); 189 public RunOnMainSyncFutureTask(Callable<V> callable) { argument 190 super(callable);
|
/external/guice/core/src/com/google/inject/internal/ |
H A D | ProvisionListenerStackCallback.java | 63 public T provision(Errors errors, InternalContext context, ProvisionCallback<T> callable) argument 65 Provision provision = new Provision(errors, context, callable); 97 final ProvisionCallback<T> callable; field in class:ProvisionListenerStackCallback.Provision 103 public Provision(Errors errors, InternalContext context, ProvisionCallback<T> callable) { argument 104 this.callable = callable; 115 result = callable.call();
|
/external/guice/extensions/servlet/test/com/google/inject/servlet/ |
H A D | ContinuingRequestIntegrationTest.java | 200 @Inject OffRequestCallable callable; field in class:ContinuingRequestIntegrationTest.ContinuingServlet 211 Callable<String> task = ServletScopes.continueRequest(callable,
|
/external/javaparser/javaparser-core-generators/src/main/java/com/github/javaparser/generator/ |
H A D | Generator.java | 57 * Utility method that looks for a method or constructor with an identical signature as "callable" and replaces it 58 * with callable. If not found, adds callable. When the new callable has no javadoc, any old javadoc will be kept. 60 protected void addOrReplaceWhenSameSignature(ClassOrInterfaceDeclaration containingClassOrInterface, CallableDeclaration<?> callable) { argument 61 addMethod(containingClassOrInterface, callable, () -> containingClassOrInterface.addMember(callable)); 65 * Utility method that looks for a method or constructor with an identical signature as "callable" and replaces it 66 * with callable. If not found, fails. When the new callable ha 69 replaceWhenSameSignature(ClassOrInterfaceDeclaration containingClassOrInterface, CallableDeclaration<?> callable) argument 76 addMethod( ClassOrInterfaceDeclaration containingClassOrInterface, CallableDeclaration<?> callable, Runnable onNoExistingMethod) argument 98 removeMethodWithSameSignature(ClassOrInterfaceDeclaration containingClassOrInterface, CallableDeclaration<?> callable) argument [all...] |
/external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/shadows/ |
H A D | ProgressDialogTest.java | 127 Callable<ProgressDialog> callable) throws Exception { 131 dialog = callable.call(); 125 assertLatestDialogsSet(CharSequence expectedTitle, CharSequence expectedMessage, boolean expectedIndeterminate, boolean expectedCancelable, DialogInterface.OnCancelListener expectedCancelListener, Callable<ProgressDialog> callable) argument
|
/external/v8/src/builtins/ |
H A D | builtins-global.cc | 147 Callable callable = CodeFactory::NonNumberToNumber(assembler.isolate()); local 148 var_num.Bind(assembler.CallStub(callable, context, num)); 200 Callable callable = CodeFactory::NonNumberToNumber(assembler.isolate()); local 201 var_num.Bind(assembler.CallStub(callable, context, num));
|
/external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
H A D | SameThreadScheduledExecutorService.java | 142 return schedule(java.util.concurrent.Executors.callable(command), 176 public <V> ListenableScheduledFuture<V> schedule(final Callable<V> callable, argument 178 Preconditions.checkNotNull(callable, "callable must not be null!"); 180 ListenableFuture<V> delegateFuture = submit(callable);
|
H A D | TestingExecutors.java | 131 Callable<V> callable, long delay, TimeUnit unit) { 130 schedule( Callable<V> callable, long delay, TimeUnit unit) argument
|
/external/guice/core/test/com/google/inject/ |
H A D | PerformanceComparison.java | 156 static void iterate(Callable<Foo> callable, String label) { argument 163 callable.call(); 176 static void concurrentlyIterate(final Callable<Foo> callable, String label) { argument 187 validate(callable);
|
/external/guice/extensions/servlet/src/com/google/inject/servlet/ |
H A D | GuiceFilter.java | 199 synchronized <T> T call(Callable<T> callable) throws Exception { argument 203 return callable.call();
|
H A D | ServletScopes.java | 183 * Wraps the given callable in a contextual callable that "continues" the 199 * <p>The returned callable will throw a {@link ScopingException} when called 202 * @param callable code to be executed in another thread, which depends on 207 * @return a callable that will invoke the given callable, making the request 214 public static <T> Callable<T> continueRequest(final Callable<T> callable, argument 233 .call(callable); 239 * Wraps the given callable in a contextual callable tha 261 transferRequest(Callable<T> callable) argument 267 transferHttpRequest(final Callable<T> callable) argument 279 transferNonHttpRequest(final Callable<T> callable) argument 323 scopeRequest(final Callable<T> callable, Map<Key<?>, Object> seedMap) argument 371 call(Callable<T> callable) argument [all...] |