HomeSort by relevance Sort by last modified time
    Searched refs:FutureTask (Results 1 - 25 of 117) sorted by null

1 2 3 4 5

  /frameworks/base/packages/StatementService/src/com/android/statementservice/
ExceptionLoggingFutureTask.java 23 import java.util.concurrent.FutureTask;
26 * {@link FutureTask} that logs unhandled exceptions.
28 final class ExceptionLoggingFutureTask<V> extends FutureTask<V> {
  /external/guava/guava/src/com/google/common/util/concurrent/
ListenableFutureTask.java 21 import java.util.concurrent.FutureTask;
26 * A {@link FutureTask} that also implements the {@link ListenableFuture}
27 * interface. Unlike {@code FutureTask}, {@code ListenableFutureTask} does not
28 * provide an overrideable {@link FutureTask#done() done()} method. For similar
36 public class ListenableFutureTask<V> extends FutureTask<V>
ListenableFuture.java 22 import java.util.concurrent.FutureTask;
72 * <li>If they are manually filled in by a call to {@link FutureTask#set} or a
  /external/guice/extensions/service/src/com/google/inject/service/
AsyncService.java 24 import java.util.concurrent.FutureTask;
51 return new FutureTask<State>(DO_NOTHING, State.STARTED);
76 return new FutureTask<State>(DO_NOTHING, State.STOPPED);
CompositeService.java 31 import java.util.concurrent.FutureTask;
104 private FutureTask<Service.State> futureGet(final List<Future<Service.State>> tasks,
106 return new FutureTask<Service.State>(new Callable<Service.State>() {
  /frameworks/base/tests/Camera2Tests/SmartCamera/SimpleCamera/tests/src/androidx/media/filterfw/
MffTestCase.java 25 import java.util.concurrent.FutureTask;
43 FutureTask<MffContext> task = new FutureTask<MffContext>(new Callable<MffContext>() {
  /external/guava/guava-bootstrap/src/java/util/concurrent/
AbstractExecutorService.java 19 FutureTask<Object> ftask = new FutureTask<Object>(task, null);
26 FutureTask<T> ftask = new FutureTask<T>(task, result);
33 FutureTask<T> ftask = new FutureTask<T>(task);
128 FutureTask<T> f = new FutureTask<T>(t);
160 futures.add(new FutureTask<T>(t));
  /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/
RobolectricBackgroundExecutorService.java 11 import java.util.concurrent.FutureTask;
43 return schedule(new FutureTask<T>(tCallable));
48 return schedule(new FutureTask<T>(runnable, t));
56 private <T> Future<T> schedule(final FutureTask<T> futureTask) {
60 futureTask.run();
64 return futureTask;
  /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/shadows/
ShadowAsyncTask.java 13 import java.util.concurrent.FutureTask;
22 private final FutureTask<Result> future;
28 future = new FutureTask<Result>(worker) {
  /libcore/luni/src/main/java/java/util/concurrent/
ExecutorCompletionService.java 83 * FutureTask extension to enqueue upon completion.
85 private static class QueueingFuture<V> extends FutureTask<Void> {
99 return new FutureTask<V>(task);
106 return new FutureTask<V>(task, result);
FutureTask.java 22 * <p>A {@code FutureTask} can be used to wrap a {@link Callable} or
23 * {@link Runnable} object. Because {@code FutureTask} implements
24 * {@code Runnable}, a {@code FutureTask} can be submitted to an
33 * @param <V> The result type returned by this FutureTask's {@code get} methods
35 public class FutureTask<V> implements RunnableFuture<V> {
98 * Creates a {@code FutureTask} that will, upon running, execute the
104 public FutureTask(Callable<V> callable) {
112 * Creates a {@code FutureTask} that will, upon running, execute the
120 * {@code Future<?> f = new FutureTask<Void>(runnable, null)}
123 public FutureTask(Runnable runnable, V result)
    [all...]
  /external/droiddriver/src/io/appium/droiddriver/util/
InstrumentationUtils.java 28 import java.util.concurrent.FutureTask;
114 FutureTask<Void> emptyTask = new FutureTask<Void>(EMPTY_RUNNABLE, null);
149 final RunOnMainSyncFutureTask<V> futureTask = new RunOnMainSyncFutureTask<>(callable);
153 futureTask.runOnMainSyncNoThrow();
158 futureTask.runOnMainSyncNoThrow();
164 return futureTask.get(runOnMainSyncTimeoutMillis, TimeUnit.MILLISECONDS);
171 futureTask.cancel(false);
175 private static class RunOnMainSyncFutureTask<V> extends FutureTask<V> {
  /frameworks/base/packages/MtpDocumentsProvider/tests/src/com/android/mtp/
MtpManagerTest.java 34 import java.util.concurrent.FutureTask;
63 final FutureTask<Boolean> future = new FutureTask<Boolean>(
  /packages/apps/ContactsCommon/TestCommon/src/com/android/contacts/common/test/
IntegrationTestUtils.java 39 import java.util.concurrent.FutureTask;
94 FutureTask<T> future = new FutureTask<T>(callable);
  /external/glide/library/src/main/java/com/bumptech/glide/load/engine/executor/
FifoPriorityThreadPoolExecutor.java 3 import java.util.concurrent.FutureTask;
61 static class LoadTask<T> extends FutureTask<T> implements Comparable<LoadTask<?>> {
  /libcore/jsr166-tests/src/test/java/jsr166/
FutureTaskTest.java 25 import java.util.concurrent.FutureTask;
95 if (f instanceof FutureTask) {
96 FutureTask ft = (FutureTask<?>) f;
169 static class PublicFutureTask extends FutureTask {
240 new FutureTask(null);
250 new FutureTask(null, Boolean.TRUE);
726 final FutureTask task = new FutureTask(new NoOpCallable());
755 final FutureTask task = new FutureTask(new NoOpCallable())
    [all...]
ExecutorCompletionServiceTest.java 19 import java.util.concurrent.FutureTask;
163 class MyCallableFuture<V> extends FutureTask<V> {
194 class MyRunnableFuture<V> extends FutureTask<V> {
  /external/droiddriver/src/io/appium/droiddriver/base/
BaseUiElement.java 29 import java.util.concurrent.FutureTask;
190 protected abstract void doPerformAndWait(FutureTask<Boolean> futureTask, long timeoutMillis);
193 FutureTask<Boolean> futureTask = new FutureTask<Boolean>(new Callable<Boolean>() {
199 doPerformAndWait(futureTask, action.getTimeoutMillis());
202 return futureTask.get();
  /cts/tests/tests/media/src/android/media/cts/
MediaPlayerFlakyNetworkTest.java 40 import java.util.concurrent.FutureTask;
222 FutureTask<MediaPlayer> future = new FutureTask<MediaPlayer>(callable);
  /cts/tests/tests/networksecurityconfig/networksecurityconfig-downloadmanager/src/android/security/net/config/cts/
DownloadManagerTest.java 50 import java.util.concurrent.FutureTask;
84 FutureTask<Void> serverFuture = new FutureTask<Void>(new Callable() {
  /developers/build/prebuilts/gradle/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/
AsyncTask.java 31 import java.util.concurrent.FutureTask;
64 * {@link java.util.concurrent.ThreadPoolExecutor} and {@link java.util.concurrent.FutureTask}.</p>
240 private final FutureTask<Result> mFuture;
317 mFuture = new FutureTask<Result>(mWorker) {
  /developers/samples/android/ui/graphics/DisplayingBitmaps/Application/src/main/java/com/example/android/displayingbitmaps/util/
AsyncTask.java 31 import java.util.concurrent.FutureTask;
64 * {@link java.util.concurrent.ThreadPoolExecutor} and {@link java.util.concurrent.FutureTask}.</p>
240 private final FutureTask<Result> mFuture;
317 mFuture = new FutureTask<Result>(mWorker) {
  /development/samples/browseable/DisplayingBitmaps/src/com.example.android.displayingbitmaps/util/
AsyncTask.java 31 import java.util.concurrent.FutureTask;
64 * {@link java.util.concurrent.ThreadPoolExecutor} and {@link java.util.concurrent.FutureTask}.</p>
240 private final FutureTask<Result> mFuture;
317 mFuture = new FutureTask<Result>(mWorker) {
  /frameworks/base/core/java/android/os/
AsyncTask.java 28 import java.util.concurrent.FutureTask;
47 * {@link ThreadPoolExecutor} and {@link FutureTask}.</p>
228 private final FutureTask<Result> mFuture;
310 mFuture = new FutureTask<Result>(mWorker) {
  /frameworks/support/compat/java/android/support/v4/content/
ModernAsyncTask.java 24 import java.util.concurrent.FutureTask;
82 private final FutureTask<Result> mFuture;
142 mFuture = new FutureTask<Result>(mWorker) {

Completed in 3848 milliseconds

1 2 3 4 5