| /external/guava/guava-bootstrap/src/java/util/concurrent/ |
| D | AbstractExecutorService.java | 17 public Future<?> submit(Runnable task) { in submit()
24 public <T> Future<T> submit(Runnable task, T result) { in submit()
31 public <T> Future<T> submit(Callable<T> task) { in submit()
46 List<Future<T>> futures= new ArrayList<Future<T>>(ntasks); in doInvokeAny()
60 Future<T> f = ecs.poll(); in doInvokeAny()
99 for (Future<T> f : futures) in doInvokeAny()
120 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
124 List<Future<T>> futures = new ArrayList<Future<T>>(tasks.size()); in invokeAll()
132 for (Future<T> f : futures) { in invokeAll()
145 for (Future<T> f : futures) in invokeAll()
[all …]
|
| D | ExecutorService.java | 28 <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/llvm/lib/Support/ |
| D | ThreadPool.cpp | 88 auto Future = PackagedTask.get_future(); in asyncImpl() local
99 return Future.share(); in asyncImpl()
142 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl() local
145 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); in asyncImpl()
147 auto Future = std::async(std::launch::deferred, std::move(Task), false).share(); in asyncImpl()
148 PackagedTaskTy PackagedTask([Future](bool) -> bool { Future.get(); return false; }); in asyncImpl()
151 return Future; in asyncImpl()
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | ForwardingFuture.java | 23 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()
|
| D | JdkFutureAdapters.java | 26 import java.util.concurrent.Future;
59 Future<V> future) { in listenInPoolThread()
91 Future<V> future, Executor executor) { in listenInPoolThread()
130 private final Future<V> delegate;
132 ListenableFutureAdapter(Future<V> delegate) { in ListenableFutureAdapter()
136 ListenableFutureAdapter(Future<V> delegate, Executor adapterExecutor) { in ListenableFutureAdapter()
142 protected Future<V> delegate() { in delegate()
|
| D | ForwardingExecutorService.java | 26 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()
|
| D | WrappingExecutorService.java | 30 import java.util.concurrent.Future;
99 public final <T> Future<T> submit(Callable<T> task) {
104 public final Future<?> submit(Runnable task) {
109 public final <T> Future<T> submit(Runnable task, T result) {
114 public final <T> List<Future<T>> invokeAll(
120 public final <T> List<Future<T>> invokeAll(
|
| D | AbstractScheduledService.java | 29 import java.util.concurrent.Future;
125 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedDelaySchedule()
144 public Future<?> schedule(AbstractService service, ScheduledExecutorService executor, in newFixedRateSchedule()
152 abstract Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
163 private volatile Future<?> runningTask;
426 private Future<Void> currentFuture;
482 protected Future<Void> delegate() {
488 final Future<?> schedule(AbstractService service, ScheduledExecutorService executor,
|
| D | ListeningExecutorService.java | 23 import java.util.concurrent.Future;
74 <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
95 <T> List<Future<T>> invokeAll( in invokeAll()
|
| /external/robolectric/v1/src/main/java/com/xtremelabs/robolectric/util/ |
| D | RobolectricBackgroundExecutorService.java | 10 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/guice/extensions/service/src/com/google/inject/service/ |
| D | CompositeService.java | 30 import java.util.concurrent.Future;
80 public Future<State> start() { in compose()
81 final List<Future<State>> tasks = Lists.newArrayList(); in compose()
89 public Future<State> stop() { in compose()
90 final List<Future<State>> tasks = Lists.newArrayList(); in compose()
104 private FutureTask<Service.State> futureGet(final List<Future<Service.State>> tasks,
109 for (Future<Service.State> task : tasks) {
|
| D | Service.java | 20 import java.util.concurrent.Future;
41 Future<State> start(); in start()
54 Future<State> stop(); in stop()
|
| D | AsyncService.java | 23 import java.util.concurrent.Future;
45 public synchronized final Future<State> start() { in start()
71 public synchronized final Future<State> stop() {
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | WrappingExecutorServiceTest.java | 35 import java.util.concurrent.Future;
74 Future<?> f = testExecutor.submit(doNothing()); in testSubmit()
81 Future<String> f = testExecutor.submit(doNothing(), RESULT_VALUE); in testSubmit()
89 Future<String> f = testExecutor.submit(task); in testSubmit()
100 List<Future<String>> futures = testExecutor.invokeAll(tasks); in testInvokeAll()
109 List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit); in testInvokeAll()
135 private static void checkResults(List<Future<String>> futures) in checkResults()
213 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
221 public <T> List<Future<T>> invokeAll( in invokeAll()
272 public <T> Future<T> submit(Callable<T> task) { in submit()
[all …]
|
| D | WrappingScheduledExecutorServiceTest.java | 26 import java.util.concurrent.Future;
169 public <T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks) in invokeAll()
175 public <T> List<Future<T>> invokeAll( in invokeAll()
214 public <T> Future<T> submit(Callable<T> task) { in submit()
219 public Future<?> submit(Runnable task) { in submit()
224 public <T> Future<T> submit(Runnable task, T result) { in submit()
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| D | TestingExecutorsTest.java | 29 import java.util.concurrent.Future;
73 List<Future<Boolean>> futureList = executor.invokeAll( in testNoOpScheduledExecutorInvokeAll()
75 Future<Boolean> future = futureList.get(0); in testNoOpScheduledExecutorInvokeAll()
94 Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule( in testSameThreadScheduledExecutor()
107 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); in testSameThreadScheduledExecutorWithException()
|
| /external/conscrypt/openjdk/src/test/java/org/conscrypt/ |
| D | NativeCryptoTest.java | 64 import java.util.concurrent.Future;
1026 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener, in handshake()
1030 Future<TestSSLHandshakeCallbacks> future = in handshake()
1124 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null); in test_SSL_do_handshake_normal()
1125 Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null); in test_SSL_do_handshake_normal()
1149 Future<TestSSLHandshakeCallbacks> client1 = in test_SSL_do_handshake_reusedSession()
1156 Future<TestSSLHandshakeCallbacks> server1 = handshake(listener, 0, in test_SSL_do_handshake_reusedSession()
1185 Future<TestSSLHandshakeCallbacks> client2 = in test_SSL_do_handshake_reusedSession()
1194 Future<TestSSLHandshakeCallbacks> server2 = handshake(listener, 0, in test_SSL_do_handshake_reusedSession()
1246 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null); in test_SSL_do_handshake_optional_client_certificate()
[all …]
|
| /external/testng/src/main/java/org/testng/internal/thread/ |
| D | FutureResultAdapter.java | 5 import java.util.concurrent.Future;
13 Future<?> m_future;
15 public FutureResultAdapter(Future<?> future) { in FutureResultAdapter()
|
| /external/jacoco/org.jacoco.agent.rt.test/src/org/jacoco/agent/rt/internal/output/ |
| D | MockServerSocketTest.java | 25 import java.util.concurrent.Future;
84 final Future<Socket> f = executor.submit(new Callable<Socket>() { in testCloseWhileAccept()
100 final Future<Socket> f = executor.submit(new Callable<Socket>() { in testAccept()
121 final Future<Socket> f = executor.submit(new Callable<Socket>() { in testConnect()
137 final Future<Void> f = executor.submit(new Callable<Void>() { in testWaitForAccept()
|
| D | TcpConnectionTest.java | 22 import java.util.concurrent.Future;
89 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteClose()
118 final Future<Void> f = executor.submit(new Callable<Void>() { in testLocalClose()
144 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteDump()
172 final Future<Void> f = executor.submit(new Callable<Void>() { in testLocalDump()
229 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteReset()
|
| /external/clang/test/SemaCXX/ |
| D | decltype.cpp | 20 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/r8/src/main/java/com/android/tools/r8/utils/ |
| D | ThreadUtils.java | 11 import java.util.concurrent.Future;
15 public static <T> List<T> awaitFutures(List<? extends Future<? extends T>> futures) in awaitFutures()
18 for (Future<? extends T> f : futures) { in awaitFutures()
|
| /external/r8/src/test/examples/sync/ |
| D | Sync.java | 9 import java.util.concurrent.Future;
96 Future[] results = new Future[ITERATIONS]; in run()
106 for (Future result : results) { in run()
|
| /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()
61 for (Future<?> future : futures) { in single_mock_being_serialized_in_different_classloaders_by_multiple_threads()
|
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| D | RobolectricBackgroundExecutorServiceTest.java | 10 import java.util.concurrent.Future;
47 Future<String> future = executorService.submit(runnable, "foo"); in submitRunnable_shouldRunStuffOnBackgroundThread()
61 Future<String> future = executorService.submit(new Callable<String>() { in submitCallable_shouldRunStuffOnBackgroundThread()
|