| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | AbstractExecutorService.java | 46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); in doInvokeAny() local
55 futures.add(ecs.submit(it.next())); in doInvokeAny()
64 futures.add(ecs.submit(it.next())); in doInvokeAny()
99 for (Future<T> f : futures) in doInvokeAny()
124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
129 futures.add(f); in invokeAll()
132 for (Future<T> f : futures) { in invokeAll()
142 return futures; in invokeAll()
145 for (Future<T> f : futures) in invokeAll()
156 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll() local
[all …]
|
| /external/python/futures/futures.egg-info/ |
| D | SOURCES.txt | 11 concurrent/futures/__init__.py
12 concurrent/futures/_base.py
13 concurrent/futures/process.py
14 concurrent/futures/thread.py
19 futures.egg-info/PKG-INFO
20 futures.egg-info/SOURCES.txt
21 futures.egg-info/dependency_links.txt
22 futures.egg-info/not-zip-safe
23 futures.egg-info/top_level.txt
|
| D | PKG-INFO | 2 Name: futures
4 Summary: Backport of the concurrent.futures package from Python 3
13 This is a backport of the `concurrent.futures`_ standard library module to Python 2.
25 ':python_version == "2.7"': ['futures']
36 'futures; python_version == "2.7"'
43 .. _concurrent.futures: https://docs.python.org/library/concurrent.futures.html
|
| /external/guava/guava-tests/benchmark/com/google/common/util/concurrent/ |
| D | FuturesCombineBenchmark.java | 40 Iterable<? extends ListenableFuture<?>> futures) { in combine() argument
41 ListenableFuture<?> trigger = Futures.successfulAsList(futures); in combine()
60 Iterable<? extends ListenableFuture<?>> futures) {
61 return Futures.combine(combiner, executor, futures);
67 Iterable<? extends ListenableFuture<?>> futures);
84 ImmutableList<ListenableFuture<?>> futures = futuresBuilder.build();
89 sum += impl.combine(callable, INLINE_EXECUTOR, futures).get();
99 ImmutableList<ListenableFuture<?>> futures = futuresBuilder.build();
104 sum += impl.combine(callable, INLINE_EXECUTOR, futures).get();
114 ImmutableList<SettableFuture<Integer>> futures = getSettableFutureList();
[all …]
|
| /external/python/cpython3/Lib/asyncio/ |
| D | tasks.py | 12 import concurrent.futures
23 from . import futures
41 if futures._get_loop(t) is loop and not t.done()}
52 return {t for t in list(_all_tasks) if futures._get_loop(t) is loop}
55 class Task(futures._PyFuture): # Inherit Python Task implementation
120 if self._state == futures._PENDING and self._log_destroy_pending:
208 raise futures.InvalidStateError(
211 if not isinstance(exc, futures.CancelledError):
212 exc = futures.CancelledError()
230 super().set_exception(futures.CancelledError())
[all …]
|
| D | base_futures.py | 3 import concurrent.futures._base
8 Error = concurrent.futures._base.Error
9 CancelledError = concurrent.futures.CancelledError
10 TimeoutError = concurrent.futures.TimeoutError
|
| D | __init__.py | 11 from .futures import *
28 futures.__all__ +
|
| /external/python/futures/ |
| D | test_futures.py | 15 from concurrent import futures
16 from concurrent.futures._base import (
18 from concurrent.futures.thread import cpu_count
158 futures = [self.executor.submit(time.sleep, 0.1)
161 for f in futures:
166 executor_type = futures.ThreadPoolExecutor
170 executor_type = futures.ProcessPoolExecutor
215 with futures.ThreadPoolExecutor(max_workers=5) as e:
224 executor = futures.ThreadPoolExecutor(max_workers=5)
234 executor = futures.ThreadPoolExecutor(
[all …]
|
| D | PKG-INFO | 2 Name: futures
4 Summary: Backport of the concurrent.futures package from Python 3
13 This is a backport of the `concurrent.futures`_ standard library module to Python 2.
25 ':python_version == "2.7"': ['futures']
36 'futures; python_version == "2.7"'
43 .. _concurrent.futures: https://docs.python.org/library/concurrent.futures.html
|
| D | README.rst | 5 This is a backport of the `concurrent.futures`_ standard library module to Python 2.
17 ':python_version == "2.7"': ['futures']
28 'futures; python_version == "2.7"'
35 .. _concurrent.futures: https://docs.python.org/library/concurrent.futures.html
|
| D | METADATA | 1 name: "futures"
3 "Python PyPI futures package"
8 value: "https://pypi.python.org/pypi/futures/3.2.0"
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 23 from concurrent import futures
24 from concurrent.futures._base import (
27 from concurrent.futures.process import BrokenProcessPool
141 futures = [self.executor.submit(time.sleep, 0.1)
143 for f in futures:
148 executor_type = futures.ThreadPoolExecutor
152 executor_type = futures.ProcessPoolExecutor
162 executor_type = futures.ProcessPoolExecutor
167 executor_type = futures.ProcessPoolExecutor
207 futures = [self.executor.submit(get_init_status)
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | Futures.java | 1004 ListenableFuture<? extends V>... futures) {
1005 return listFuture(ImmutableList.copyOf(futures), true, directExecutor());
1026 Iterable<? extends ListenableFuture<? extends V>> futures) {
1027 return listFuture(ImmutableList.copyOf(futures), true, directExecutor());
1053 ImmutableList<ListenableFuture<?>> futures;
1055 CombinerFuture(Callable<V> callable, ImmutableList<ListenableFuture<?>> futures) {
1057 this.futures = futures;
1061 ImmutableList<ListenableFuture<?>> futures = this.futures;
1063 for (ListenableFuture<?> future : futures) {
1073 futures = null;
[all …]
|
| /external/python/cpython3/Doc/library/ |
| D | concurrent.futures.rst | 1 :mod:`concurrent.futures` --- Launching parallel tasks
4 .. module:: concurrent.futures
9 **Source code:** :source:`Lib/concurrent/futures/thread.py`
10 and :source:`Lib/concurrent/futures/process.py`
14 The :mod:`concurrent.futures` module provides a high-level interface for
50 The returned iterator raises a :exc:`concurrent.futures.TimeoutError`
73 when the currently pending futures are done executing. Calls to
78 pending futures are done executing and the resources associated with the
81 freed when all pending futures are done executing. Regardless of the
83 pending futures are done executing.
[all …]
|
| /external/tensorflow/tensorflow/tools/test/ |
| D | check_futures_test.py | 58 futures = set()
66 futures.add(m.group(1))
71 futures.add(entry)
78 if futures != expected:
81 (' '.join(expected), ' '.join(futures)))
83 missing = REQUIRED_FUTURES - futures
|
| /external/python/futures/concurrent/futures/ |
| D | __init__.py | 8 from concurrent.futures._base import (FIRST_COMPLETED,
17 from concurrent.futures.thread import ThreadPoolExecutor
20 from concurrent.futures.process import ProcessPoolExecutor
|
| /external/python/futures/docs/ |
| D | index.rst | 1 :mod:`concurrent.futures` --- Asynchronous computation
4 .. module:: concurrent.futures
7 The :mod:`concurrent.futures` module provides a high-level interface for
47 the currently pending futures are done executing. Calls to
52 futures are done executing and the resources associated with the executor
55 when all pending futures are done executing. Regardless of the value of
56 *wait*, the entire Python program will not exit until all pending futures
123 from concurrent import futures
135 with futures.ThreadPoolExecutor(max_workers=5) as executor:
139 for future in futures.as_completed(future_to_url):
[all …]
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _thread_pool.py | 16 from concurrent import futures
19 class RecordingThreadPool(futures.Executor):
23 self._tp_executor = futures.ThreadPoolExecutor(max_workers=max_workers)
|
| D | _server_test.py | 15 from concurrent import futures
32 futures.ThreadPoolExecutor(max_workers=5),
41 server = grpc.server(futures.ThreadPoolExecutor(max_workers=5))
|
| D | _resource_exhausted_test.py | 153 futures = []
155 futures.append(multi_callable.future(_REQUEST))
170 for future in futures:
203 futures = []
206 futures.append(multi_callable.future(request))
222 for future in futures:
|
| D | _channel_args_test.py | 16 from concurrent import futures
44 futures.ThreadPoolExecutor(max_workers=1),
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_futures.py | 3 import concurrent.futures
12 from asyncio import futures
335 from asyncio.futures import _copy_future_state
436 ex = concurrent.futures.ThreadPoolExecutor(1)
455 ex = concurrent.futures.ThreadPoolExecutor(1)
462 f1 = concurrent.futures.Future()
470 f1 = concurrent.futures.Future()
526 futures._set_result_unless_cancelled(fut, 2)
561 @unittest.skipUnless(hasattr(futures, '_CFuture'),
565 cls = futures._CFuture
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll() local
102 checkResults(futures); in testInvokeAll()
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll() local
111 checkResults(futures); in testInvokeAll()
135 private static void checkResults(List<Future<String>> futures) in checkResults() argument
137 for (int i = 0; i < futures.size(); i++) { in checkResults()
138 assertEquals(RESULT_VALUE + i, futures.get(i).get()); in checkResults()
|
| /external/mockito/src/test/java/org/mockitousage/serialization/ |
| D | ParallelSerializationTest.java | 33 List<Future<?>> futures = new ArrayList<Future<?>>(threadingFactor); in single_mock_being_serialized_in_different_classloaders_by_multiple_threads() local
41 futures.add(executorService.submit(new Callable<Object>() { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
61 for (Future<?> future : futures) { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
|
| /external/grpc-grpc/examples/python/helloworld/ |
| D | greeter_server.py | 16 from concurrent import futures
34 server = grpc.server(futures.ThreadPoolExecutor(max_workers=10))
|