/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();
|