Home
last modified time | relevance | path

Searched refs:Future (Results 1 – 25 of 171) sorted by relevance

1234567

/external/chromium_org/chrome/common/extensions/docs/server2/
Dfuture_test.py10 from future import All, Future, Race
16 self.assertRaises(ValueError, Future)
19 future = Future(value=42)
29 future = Future(callback=callback)
65 future = Future(callback=callback)
75 future = All((Future(callback=callback),))
84 future = All(Future(callback=callback) for callback in callbacks)
98 future = All(Future(callback=callback) for callback in callbacks)
108 future = All((Future(callback=callback) for callback in callbacks),
118 race = Race((Future(callback=callback),))
[all …]
Dcompiled_file_system.py9 from future import Future
160 return Future(value=None)
189 return Future(exc_info=sys.exc_info())
192 return Future(value=first_layer_files)
229 return Future(exc_info=sys.exc_info())
233 return Future(value=cache_entry.cache_data)
252 return Future(exc_info=sys.exc_info())
256 return Future(value=cache_entry.cache_data)
272 return Future(value=cache_entry.version)
274 return Future(callback=lambda: stat_future.Get().version)
[all …]
Dfuture.py38 return Future(callback=resolve)
64 return Future(callback=resolve)
67 class Future(object): class
114 return val.Get() if isinstance(val, Future) else val
115 return Future(callback=then)
Dplatform_bundle.py15 from future import Future
89 Future(callback=lambda: self.GetReferenceResolver(platform)),
90 Future(callback=lambda: self.GetAPIModels(platform)),
91 Future(callback=lambda: self.GetFeaturesBundle(platform)),
114 Future(callback=lambda: self.GetReferenceResolver(platform)),
115 Future(callback=lambda: self.GetAPIModels(platform)),
116 Future(callback=lambda: self.GetFeaturesBundle(platform)),
Doffline_file_system.py6 from future import Future
17 if skip_not_found: return Future(value={})
20 return Future(callback=raise_file_not_found)
Dempty_dir_file_system.py6 from future import Future
21 return Future(value=result)
24 return Future(value=())
Dfile_system.py8 from future import Future
26 return Future(callback=boom)
106 return Future(callback=lambda: read_single.Get().get(path, None))
119 return Future(value=True)
159 return Future(callback=lambda: self.Stat(path))
Dgithub_file_system.py15 from future import Future
100 self._zip_file = Future(value=None)
104 self._zip_file = Future(value=ZipFile(StringIO(blob)))
108 self._zip_file = Future(value=None)
110 self._zip_file = Future(
159 return Future(value=result)
Dlocal_file_system.py10 from future import Future
96 return Future(exc_info=sys.exc_info())
98 return Future(callback=resolve)
101 return Future(value=())
Dapi_data_source.py11 from future import Future, All
44 self._event_byname_futures[platform] = Future(
68 return Future(callback=resolve)
84 return Future(callback=resolve)
/external/guava/guava/src/com/google/common/util/concurrent/
DAbstractListeningExecutorService.java27 import java.util.concurrent.Future;
67 List<Future<T>> futures = new ArrayList<Future<T>>(ntasks); in doInvokeAny()
89 Future<T> f = ecs.poll(); in doInvokeAny()
126 for (Future<T> f : futures) { in doInvokeAny()
147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
152 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll()
160 for (Future<T> f : futures) { in invokeAll()
173 for (Future<T> f : futures) { in invokeAll()
180 @Override public <T> List<Future<T>> invokeAll( in invokeAll()
187 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll()
[all …]
DForwardingFuture.java23 import java.util.concurrent.Future;
39 implements Future<V> {
44 @Override protected abstract Future<V> delegate(); in delegate()
84 private final Future<V> delegate;
86 protected SimpleForwardingFuture(Future<V> delegate) { in SimpleForwardingFuture()
91 protected final Future<V> delegate() { in delegate()
DJdkFutureAdapters.java26 import java.util.concurrent.Future;
59 Future<V> future) { in listenInPoolThread()
68 Future<V> future, Executor executor) { in listenInPoolThread()
107 private final Future<V> delegate;
109 ListenableFutureAdapter(Future<V> delegate) { in ListenableFutureAdapter()
113 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
119 protected Future<V> delegate() { in delegate()
DForwardingExecutorService.java26 import java.util.concurrent.Future;
54 public <T> List<Future<T>> invokeAll( in invokeAll()
60 public <T> List<Future<T>> invokeAll( in invokeAll()
104 public <T> Future<T> submit(Callable<T> task) { in submit()
109 public Future<?> submit(Runnable task) { in submit()
114 public <T> Future<T> submit(Runnable task, T result) { in submit()
DAbstractScheduledService.java25 import java.util.concurrent.Future;
120 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedDelaySchedule()
139 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedRateSchedule()
147 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
158 private volatile Future<?> runningTask;
331 private Future<Void> currentFuture;
387 protected Future<Void> delegate() {
393 final Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
DListeningExecutorService.java23 import java.util.concurrent.Future;
69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
85 <T> List<Future<T>> invokeAll( in invokeAll()
/external/robolectric/src/main/java/com/xtremelabs/robolectric/util/
DRobolectricBackgroundExecutorService.java10 import java.util.concurrent.Future;
42 public <T> Future<T> submit(Callable<T> tCallable) { in submit()
47 public <T> Future<T> submit(Runnable runnable, T t) { in submit()
52 public Future<?> submit(Runnable runnable) { in submit()
56 private <T> Future<T> schedule(final FutureTask<T> futureTask) { in schedule()
68 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws Interrupt… in invokeAll()
73 …public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit… in invokeAll()
/external/guava/guava-tests/test/com/google/common/util/concurrent/
DAbstractListeningExecutorServiceTest.java29 import java.util.concurrent.Future;
61 Future<?> future = e.submit(task); in testExecuteRunnable()
71 Future<String> future = e.submit(new StringTask()); in testSubmitCallable()
81 Future<?> future = e.submit(new NoOpRunnable()); in testSubmitRunnable()
91 Future<String> future = e.submit(new NoOpRunnable(), TEST_STRING); in testSubmitRunnable2()
104 Future future = e.submit(Executors.callable( in testSubmitPrivilegedAction()
127 Future future = e.submit(Executors.callable( in testSubmitPrivilegedExceptionAction()
147 Future future = e.submit(Executors.callable( in testSubmitFailedPrivilegedExceptionAction()
206 Future<Void> future = p.submit(awaiter); in testInterruptedSubmit()
346 List<Future<String>> r = in testInvokeAll2()
[all …]
DMoreExecutorsTest.java35 import java.util.concurrent.Future;
72 Future<?> future = executor.submit(incrementTask); in testSameThreadExecutorServiceInThreadExecution()
113 List<Future<Integer>> futures = in testSameThreadExecutorInvokeAll()
117 Future<Integer> future = futures.get(i); in testSameThreadExecutorInvokeAll()
139 Future<?> future = executor.submit(new Callable<Void>() { in testSameThreadExecutorServiceTermination()
211 List<Future<String>> results; in testListeningDecorator()
/external/guava/guava-bootstrap/src/java/util/concurrent/
DExecutorService.java28 <T> Future<T> submit(Callable<T> task); in submit()
30 <T> Future<T> submit(Runnable task, T result); in submit()
32 Future<?> submit(Runnable task); in submit()
34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
37 <T> List<Future<T>> invokeAll( in invokeAll()
/external/clang/test/SemaCXX/
Ddecltype.cpp20 struct Future { struct
21 explicit Future(T v);
36 Future<int> f1(42); in rdar16527205() argument
37 f1.call([](int){ return Future<float>(0); }); in rdar16527205()
/external/conscrypt/src/test/java/org/conscrypt/
DNativeCryptoTest.java50 import java.util.concurrent.Future;
935 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener, in handshake()
939 Future<TestSSLHandshakeCallbacks> future = executor.submit( in handshake()
1018 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_normal()
1019 … Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, null); in test_SSL_do_handshake_normal()
1058 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_optional_client_certificate()
1059 … Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, null); in test_SSL_do_handshake_optional_client_certificate()
1109 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, in test_SSL_do_handshake_missing_required_certificate()
1111 Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, in test_SSL_do_handshake_missing_required_certificate()
1174 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_clientCertificateRequested_throws_after_renegotiate()
[all …]
/external/junit/src/org/junit/experimental/
DParallelComputer.java8 import java.util.concurrent.Future;
38 private final List<Future<Object>> fResults= new ArrayList<Future<Object>>(); in parallelize()
53 for (Future<Object> each : fResults) in parallelize()
/external/chromium_org/third_party/WebKit/Source/devtools/scripts/jsdoc-validator/src/org/chromium/devtools/jsdoc/
DJsDocValidator.java16 import java.util.concurrent.Future;
31 List<Future<ValidatorContext>> futures = new ArrayList<>(args.length); in runWithExecutor()
32 Map<Future<ValidatorContext>, String> fileNamesByFuture = new HashMap<>(); in runWithExecutor()
34 Future<ValidatorContext> future = executor.submit(new FileCheckerCallable(fileName)); in runWithExecutor()
40 for (Future<ValidatorContext> future : futures) { in runWithExecutor()
/external/chromium_org/components/devtools_bridge/android/javatests/src/org/chromium/components/devtools_bridge/
DLocalTunnelBridgeTest.java15 import java.util.concurrent.Future;
68 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST); in testRequestResponse()
86 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST); in testRequestFailure1()
104 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST); in testRequestFailure2()

1234567