/external/chromium_org/chrome/common/extensions/docs/server2/ |
H A D | offline_file_system.py | 6 from future import Future namespace 17 if skip_not_found: return Future(value={}) 20 return Future(callback=raise_file_not_found)
|
H A D | future_test.py | 10 from future import All, Future, Race namespace 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(callbac [all...] |
H A D | empty_dir_file_system.py | 6 from future import Future namespace 21 return Future(value=result) 24 return Future(value=())
|
H A D | future.py | 17 '''Creates a Future which returns a list of results from each Future in 20 If any Future raises an error other than those in |except_pass| the returned 21 Future will raise as well. 23 If any Future raises an error in |except_pass| then None will be inserted as 38 return Future(callback=resolve) 42 '''Returns a Future which resolves to the first Future in |futures| that 64 return Future(callback=resolve) 67 class Future(objec class in inherits:object [all...] |
H A D | test_patcher.py | 5 from future import Future namespace 29 return Future(value=dict((path, self._patch_data[path])
|
H A D | compiled_file_system.py | 9 from future import Future namespace 160 return Future(value=None) 167 '''Returns a Future containing the recursive directory listing of |path| as 183 # asynchronous Future contract) because there's a greater chance to 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(valu [all...] |
H A D | platform_bundle.py | 15 from future import Future namespace 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)),
|
H A D | cache_chain_object_store.py | 5 from future import Future namespace 43 return Future(value=cached_items) 50 # Don't realise the Future value of an object store that we don't need to; 75 return Future(callback=resolve)
|
H A D | permissions_data_source.py | 10 from future import Future namespace 74 return Future(callback=resolve) 84 return Future(callback=resolve)
|
H A D | local_file_system.py | 10 from future import Future namespace 96 return Future(exc_info=sys.exc_info()) 98 return Future(callback=resolve) 101 return Future(value=())
|
H A D | object_store.py | 5 from future import Future namespace 12 '''Gets a |Future| with the value of |key| in the object store, or None 18 '''Gets a |Future| with values mapped to |keys| from the object store, with
|
/external/guava/guava/src/com/google/common/util/concurrent/ |
H A D | ListenableFuture.java | 21 import java.util.concurrent.Future; 26 * A {@link Future} that accepts completion listeners. Each listener has an 28 * computation is {@linkplain Future#isDone() complete}. If the computation has 35 * derived {@code Future}, as in {@link Futures#allAsList(Iterable) 41 * access to the {@code Future} result. (Users who want such access may prefer 61 * depends on how they currently create {@code Future} instances: 73 * Occasionally, an API will return a plain {@code Future} and it will be 82 public interface ListenableFuture<V> extends Future<V> { 85 * the given executor. The listener will run when the {@code Future}'s 86 * computation is {@linkplain Future#isDon [all...] |
H A D | ForwardingFuture.java | 23 import java.util.concurrent.Future; 28 * A {@link Future} which forwards all its method calls to another future. 39 implements Future<V> { 44 @Override protected abstract Future<V> delegate(); 78 * can pass in an already constructed {@link Future} as the delegate. 84 private final Future<V> delegate; 86 protected SimpleForwardingFuture(Future<V> delegate) { 91 protected final Future<V> delegate() {
|
H A D | ListeningExecutorService.java | 23 import java.util.concurrent.Future; 69 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 85 <T> List<Future<T>> invokeAll(
|
H A D | AbstractListeningExecutorService.java | 27 import java.util.concurrent.Future; 67 List<Future<T>> futures = new ArrayList<Future<T>>(ntasks); 89 Future<T> f = ecs.poll(); 126 for (Future<T> f : futures) { 147 @Override public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 152 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); 160 for (Future<T> f : futures) { 173 for (Future< [all...] |
H A D | AsyncFunction.java | 21 import java.util.concurrent.Future; 33 * Returns an output {@code Future} to use in place of the given {@code 34 * input}. The output {@code Future} need not be {@linkplain Future#isDone 38 * failing {@code Future}.
|
H A D | FutureCallback.java | 22 import java.util.concurrent.Future; 25 * A callback for accepting the results of a {@link java.util.concurrent.Future} 36 * Invoked with the result of the {@code Future} computation when it is 42 * Invoked when a {@code Future} computation fails or is canceled. 44 * <p>If the future's {@link Future#get() get} method throws an {@link
|
H A D | JdkFutureAdapters.java | 26 import java.util.concurrent.Future; 32 * Future} instances. Note that, whenver possible, it is strongly preferred to 42 * Assigns a thread to the given {@link Future} to provide {@link 49 * until the future is {@linkplain Future#isDone() done}. 55 * Future} instances to be upgraded to {@code ListenableFuture} after the 59 Future<V> future) { 68 Future<V> future, Executor executor) { 77 * An adapter to turn a {@link Future} into a {@link ListenableFuture}. This 107 private final Future<V> delegate; 109 ListenableFutureAdapter(Future< [all...] |
H A D | ForwardingExecutorService.java | 26 import java.util.concurrent.Future; 54 public <T> List<Future<T>> invokeAll( 60 public <T> List<Future<T>> invokeAll( 104 public <T> Future<T> submit(Callable<T> task) { 109 public Future<?> submit(Runnable task) { 114 public <T> Future<T> submit(Runnable task, T result) {
|
/external/guava/guava-bootstrap/src/java/util/concurrent/ |
H A D | ExecutorService.java | 28 <T> Future<T> submit(Callable<T> task); 30 <T> Future<T> submit(Runnable task, T result); 32 Future<?> submit(Runnable task); 34 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) 37 <T> List<Future<T>> invokeAll(
|
/external/clang/test/SemaCXX/ |
H A D | decltype.cpp | 20 struct Future { struct 21 explicit Future(T v); 36 Future<int> f1(42); 37 f1.call([](int){ return Future<float>(0); });
|
/external/robolectric/src/main/java/com/xtremelabs/robolectric/util/ |
H A D | RobolectricBackgroundExecutorService.java | 10 import java.util.concurrent.Future; 42 public <T> Future<T> submit(Callable<T> tCallable) { 47 public <T> Future<T> submit(Runnable runnable, T t) { 52 public Future<?> submit(Runnable runnable) { 56 private <T> Future<T> schedule(final FutureTask<T> futureTask) { 68 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables) throws InterruptedException { 73 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> callables, long l, TimeUnit timeUnit) throws InterruptedException {
|
/external/junit/src/org/junit/experimental/ |
H A D | ParallelComputer.java | 8 import java.util.concurrent.Future; 38 private final List<Future<Object>> fResults= new ArrayList<Future<Object>>(); 53 for (Future<Object> each : fResults)
|
/external/robolectric/src/test/java/com/xtremelabs/robolectric/util/ |
H A D | RobolectricBackgroundExecutorServiceTest.java | 10 import java.util.concurrent.Future; 47 Future<String> future = executorService.submit(runnable, "foo"); 61 Future<String> future = executorService.submit(new Callable<String>() {
|
/external/chromium_org/components/devtools_bridge/android/javatests/src/org/chromium/components/devtools_bridge/ |
H A D | LocalTunnelBridgeTest.java | 15 import java.util.concurrent.Future; 68 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST); 86 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST); 104 Future<String> response = TestUtils.asyncRequest(CLIENT_SOCKET_NAME, REQUEST);
|