HomeSort by relevance Sort by last modified time
    Searched refs:Future (Results 76 - 100 of 196) sorted by null

1 2 34 5 6 7 8

  /external/chromium_org/chrome/common/extensions/docs/server2/
api_models.py 10 from future import Collect, Future
80 for future in futures:
82 return future.Get()
86 return Future(callback=resolve)
permissions_data_source.py 11 from future import Future
77 return Future(callback=resolve)
reference_resolver_test.py 9 from future import Future
252 return Future(value=Namespace(self._apis[name], 'fake/path.json'))
subversion_file_system.py 15 from future import Future
109 # A list of tuples of the form (path, Future).
114 for path, future in fetches:
116 result = future.Get()
163 return Future(callback=_GetAsyncFetchCallback(
170 return Future(value=())
207 return Future(callback=resolve)
new_github_file_system.py 17 from future import Future
144 will be set to a Future of _GithubZipFile and the fetch process started,
154 '''Returns a Future which resolves to the _GithubZipFile for this repo
172 return Future(value=repo_zip)
175 '''Returns a Future which resolves to the _GithubZipFile for this repo
197 return Future(callback=resolve)
260 return Future(callback=resolve)
caching_rietveld_patcher.py 7 from future import Future
104 return Future(value=cached_value)
content_providers.py 13 from future import Future
180 return Future(callback=
fake_url_fetcher.py 8 from future import Future
59 return Future(callback=resolve)
108 return Future(value=self.Fetch(url))
132 future = self._fetcher.FetchAsync(url, **kwargs)
135 return future.Get()
136 return Future(callback=resolve)
manifest_data_source.py 10 from future import Future
125 return Future(callback=resolve)
mock_file_system.py 8 from future import Future
54 return Future(callback=resolve)
path_canonicalizer.py 8 from future import Future
81 return Future(callback=resolve)
whats_new_data_source.py 11 from future import Future
88 return Future(callback=resolve)
  /external/glide/library/src/main/java/com/bumptech/glide/load/engine/
ResourceRunner.java 14 import java.util.concurrent.Future;
36 private volatile Future<?> future; field in class:ResourceRunner
63 if (future != null) {
64 future.cancel(false);
70 future = diskCacheService.submit(this);
92 future = resizeService.submit(sourceRunner);
  /external/guava/guava-testlib/src/com/google/common/testing/
GcFinalization.java 27 import java.util.concurrent.Future;
110 * Waits until the given future {@linkplain Future#isDone is done}, invoking the garbage
115 public static void awaitDone(Future<?> future) {
116 if (future.isDone()) {
123 if (future.isDone()) {
128 future.get(1L, SECONDS);
135 throw new RuntimeException("Unexpected interrupt while waiting for future", ie);
141 String.format("Future not done within %d second timeout", timeoutSeconds))
    [all...]
  /external/conscrypt/src/test/java/org/conscrypt/
NativeCryptoTest.java 50 import java.util.concurrent.Future;
939 Future<TestSSLHandshakeCallbacks> future = executor.submit( local
    [all...]
  /frameworks/base/services/tests/servicestests/src/com/android/server/
NetworkPolicyManagerServiceTest.java 91 import java.util.concurrent.Future;
258 final Future<Intent> backgroundChanged = mServiceContext.nextBroadcastIntent(
314 Future<Void> future; local
318 future = expectRulesChanged(UID_A, RULE_ALLOW_ALL);
321 future.get();
327 future = expectRulesChanged(UID_A, RULE_ALLOW_ALL);
330 future.get();
337 future = expectRulesChanged(UID_A, RULE_REJECT_METERED);
340 future.get()
355 Future<Void> future; local
385 Future<Void> future; local
416 Future<Void> future; local
582 Future<Void> future; local
632 Future<Void> future; local
658 Future<Void> future; local
789 Future<Void> future; local
858 final FutureAnswer future = new FutureAnswer(); local
905 final FutureAnswer future = new FutureAnswer(); local
912 final FutureAnswer future = new FutureAnswer(); local
919 final FutureAnswer future = new FutureAnswer(); local
980 final IdleFuture future = new IdleFuture(); local
    [all...]
  /external/guava/guava-tests/test/com/google/common/util/concurrent/
JdkFutureAdaptersTest.java 35 import java.util.concurrent.Future;
68 // #addListener() will run the listener immediately because the Future is
107 * A Future that doesn't implement ListenableFuture, useful for testing
118 @Override protected Future<V> delegate() {
128 implements Future<V> {
139 * Wait a little to give us time to call addListener before the future's
185 * impossible. We want the test, though, in case that changes in the future,
211 tester.setDefault(Future.class, immediateFuture(DATA1));
  /libcore/jsr166-tests/src/test/java/jsr166/
ScheduledExecutorTest.java 51 Future f = p.schedule(task, timeoutMillis(), MILLISECONDS);
73 Future f = p.schedule(task, timeoutMillis(), MILLISECONDS);
190 Future f = se.schedule(callable, SHORT_DELAY_MS, MILLISECONDS);
750 Future<String> future = e.submit(new StringTask()); local
751 String result = future.get();
764 Future<?> future = e.submit(new NoOpRunnable()); local
765 future.get();
766 assertTrue(future.isDone())
778 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); local
    [all...]
  /libcore/luni/src/test/java/libcore/javax/net/ssl/
SSLSocketTest.java 40 import java.util.concurrent.Future;
318 Future<Void> future = executor.submit(new Callable<Void>() { local
349 future.get();
375 final Future<byte[]> future1 = executor.submit(new SSLServerSessionIdCallable(server1));
388 final Future<byte[]> future2 = executor.submit(new SSLServerSessionIdCallable(server2));
411 Future<Void> future = executor.submit(new Callable<Void>() { local
427 future.get();
441 Future<Void> future = executor.submit(new Callable<Void>() local
461 Future<Void> future = executor.submit(new Callable<Void>() { local
583 Future<Void> future = executor.submit(new Callable<Void>() { local
649 Future<IOException> future = executor.submit(new Callable<IOException>() { local
703 Future<Void> future = executor.submit(new Callable<Void>() { local
733 Future<Void> future = executor.submit(new Callable<Void>() { local
805 Future<Void> future = executor.submit(new Callable<Void>() { local
852 Future<Void> future = executor.submit(new Callable<Void>() { local
894 Future<Void> future = executor.submit(new Callable<Void>() { local
923 Future<Void> future = executor.submit(new Callable<Void>() { local
1225 Future<Void> future = executor.submit(new Callable<Void>() { local
1288 Future<Void> future = executor.submit(new Callable<Void>() { local
1315 Future<Void> future = executor.submit(new Callable<Void>() { local
1355 Future<Void> future = executor.submit(new Callable<Void>() { local
    [all...]
  /libcore/luni/src/main/java/java/util/concurrent/
Executors.java 592 public Future<?> submit(Runnable task) {
595 public <T> Future<T> submit(Callable<T> task) {
598 public <T> Future<T> submit(Runnable task, T result) {
601 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)
605 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks,
  /external/guava/guava/src/com/google/common/util/concurrent/
SimpleTimeLimiter.java 35 import java.util.concurrent.Future;
126 Future<T> future = executor.submit(callable); local
130 return future.get(timeoutDuration, timeoutUnit);
132 future.cancel(true);
136 return Uninterruptibles.getUninterruptibly(future,
142 future.cancel(true);
  /external/junit/src/org/junit/internal/runners/
MethodRoadie.java 9 import java.util.concurrent.Future;
66 Future<Object> result= service.submit(callable);
  /frameworks/ex/camera2/public/src/com/android/ex/camera2/blocking/
BlockingSessionCallback.java 28 import java.util.concurrent.Future;
183 private static class SessionFuture implements Future<CameraCaptureSession> {
  /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/io/
OutputStreamTesterTest.java 43 import java.util.concurrent.Future;
117 private Future<byte[]> future; field in class:OutputStreamTesterTest.PipedOutputStreamSinkTester
124 future = executor.submit(new Callable<byte[]>() {
142 return future.get();
WriterTesterTest.java 42 import java.util.concurrent.Future;
110 private Future<char[]> future; field in class:WriterTesterTest.PipedWriterCharSinkTester
117 future = executor.submit(new Callable<char[]>() {
136 return future.get();

Completed in 458 milliseconds

1 2 34 5 6 7 8