| /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 | 85 auto Future = PackagedTask.get_future(); in asyncImpl() local
96 return Future.share(); in asyncImpl()
139 auto Future = std::async(std::launch::deferred, std::move(Task)).share(); in asyncImpl() local
142 PackagedTaskTy PackagedTask([Future]() { Future.get(); }); in asyncImpl()
144 auto Future = std::async(std::launch::deferred, std::move(Task), false).share(); in asyncImpl()
145 PackagedTaskTy PackagedTask([Future](bool) -> bool { Future.get(); return false; }); in asyncImpl()
148 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/conscrypt/src/test/java/org/conscrypt/ |
| D | NativeCryptoTest.java | 49 import java.util.concurrent.Future;
938 public static Future<TestSSLHandshakeCallbacks> handshake(final ServerSocket listener, in handshake()
942 Future<TestSSLHandshakeCallbacks> future = executor.submit( in handshake()
1021 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_normal()
1022 … Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, null); in test_SSL_do_handshake_normal()
1061 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_optional_client_certificate()
1062 … Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, null); in test_SSL_do_handshake_optional_client_certificate()
1108 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, in test_SSL_do_handshake_missing_required_certificate()
1110 Future<TestSSLHandshakeCallbacks> server = handshake(listener, 0, false, sHooks, null, in test_SSL_do_handshake_missing_required_certificate()
1173 Future<TestSSLHandshakeCallbacks> client = handshake(listener, 0, true, cHooks, null, null); in test_SSL_do_handshake_clientCertificateRequested_throws_after_renegotiate()
[all …]
|
| /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/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;
90 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteClose()
110 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteCloseWithoutHeader()
138 final Future<Void> f = executor.submit(new Callable<Void>() { in testLocalClose()
163 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteDump()
190 final Future<Void> f = executor.submit(new Callable<Void>() { in testLocalDump()
246 final Future<Void> f = executor.submit(new Callable<Void>() { in testRemoteReset()
|
| D | MockSocketConnectionTest.java | 26 import java.util.concurrent.Future;
96 final Future<Void> f = executor.submit(new Callable<Void>() { in testReadOnClosedSocketAsync()
154 final Future<Byte> f = executor.submit(new Callable<Byte>() { in testWaitForContents()
176 final Future<Byte> f = executor.submit(new Callable<Byte>() { in testCloseOtherSocketAsync()
|
| /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/junit/src/org/junit/experimental/ |
| D | ParallelComputer.java | 8 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/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()
|
| /external/glide/library/src/main/java/com/bumptech/glide/request/ |
| D | FutureTarget.java | 5 import java.util.concurrent.Future;
29 public interface FutureTarget<R> extends Future<R>, Target<R> {
|