/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));
|
H A D | MoreExecutors.java | 575 Callable<V> callable, long delay, TimeUnit unit) { 576 ListenableFutureTask<V> task = ListenableFutureTask.create(callable); 875 @Override protected <T> Callable<T> wrapTask(Callable<T> callable) { 876 return Callables.threadRenaming(callable, nameSupplier); 905 @Override protected <T> Callable<T> wrapTask(Callable<T> callable) { 906 return Callables.threadRenaming(callable, nameSupplier); 574 schedule( Callable<V> callable, long delay, TimeUnit unit) argument
|
/external/junit/src/org/junit/rules/ |
H A D | ErrorCollector.java | 73 * Adds to the table the exception, if any, thrown from {@code callable}. 75 * {@code callable} threw an exception. 77 public Object checkSucceeds(Callable<Object> callable) { argument 79 return 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/droiddriver/src/io/appium/droiddriver/util/ |
H A D | InstrumentationUtils.java | 140 * Runs {@code callable} on the main thread on best-effort basis up to a time limit, which 144 * dd.runOnMainSyncTimeout 0"} on the am command line.</p>The {@code callable} may never run, for 147 public static <V> V runOnMainSyncWithTimeout(Callable<V> callable) { argument 149 final RunOnMainSyncFutureTask<V> futureTask = new RunOnMainSyncFutureTask<>(callable); 176 public RunOnMainSyncFutureTask(Callable<V> callable) { argument 177 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/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/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...] |
/external/autotest/server/cros/dynamic_suite/ |
H A D | job_status_unittest.py | 593 def callable(x): function in function:StatusTest._prepareForReporting 596 record_entity = self.mox.CreateMock(callable)
|
/external/caliper/caliper/src/main/java/com/google/caliper/runner/ |
H A D | StreamService.java | 334 /** Returns a callable that renames the the thread that the given callable runs in. */ 335 private static <T> Callable<T> threadRenaming(final String name, final Callable<T> callable) { argument 337 checkNotNull(callable); 344 return callable.call();
|
/external/guava/guava-tests/test/com/google/common/util/concurrent/ |
H A D | WrappingExecutorServiceTest.java | 182 protected <T> Callable<T> wrapTask(Callable<T> callable) { argument 183 return new WrappedCallable<T>(callable);
|
H A D | WrappingScheduledExecutorServiceTest.java | 51 testExecutor.schedule(Executors.callable(DO_NOTHING), 5, TimeUnit.SECONDS); 97 protected <T> Callable<T> wrapTask(Callable<T> callable) { argument 98 return new WrappedCallable<T>(callable); 134 Callable<V> callable, long delay, TimeUnit unit) { 135 assertTrue(callable instanceof WrappedCallable); 133 schedule( Callable<V> callable, long delay, TimeUnit unit) argument
|