Searched refs:future1 (Results 1 – 9 of 9) sorted by relevance
| /external/python/futures/ |
| D | test_futures.py | 299 future1 = self.executor.submit(mul, 21, 2)
303 [CANCELLED_FUTURE, future1, future2],
306 self.assertEqual(set([future1]), done)
310 future1 = self.executor.submit(time.sleep, 1.5)
313 [CANCELLED_AND_NOTIFIED_FUTURE, SUCCESSFUL_FUTURE, future1],
319 self.assertEqual(set([future1]), pending)
322 future1 = self.executor.submit(mul, 2, 21)
327 [future1, future2, future3],
330 self.assertEqual(set([future1, future2]), finished)
334 future1 = self.executor.submit(divmod, 21, 0)
[all …]
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | FuturesTest.java | 117 ListenableFuture<String> future1 = Futures.immediateFuture(DATA1); in testMultipleImmediateFutures() local
121 assertSame(DATA1, future1.get(0L, TimeUnit.MILLISECONDS)); in testMultipleImmediateFutures()
172 CheckedFuture<String, MyException> future1 = Futures.immediateCheckedFuture( in testMultipleImmediateCheckedFutures() local
178 assertSame(DATA1, future1.get(0L, TimeUnit.MILLISECONDS)); in testMultipleImmediateCheckedFutures()
179 assertSame(DATA1, future1.checkedGet(0L, TimeUnit.MILLISECONDS)); in testMultipleImmediateCheckedFutures()
819 SettableFuture<String> future1 = SettableFuture.create();
824 Futures.allAsList(future1, future2, future3);
832 future1.set(DATA1);
869 SettableFuture<String> future1 = SettableFuture.create();
873 Futures.allAsList(future1, future2);
[all …]
|
| /external/python/cpython3/Lib/test/ |
| D | test_concurrent_futures.py | 446 future1 = self.executor.submit(mul, 21, 2)
450 [CANCELLED_FUTURE, future1, future2],
453 self.assertEqual(set([future1]), done)
457 future1 = self.executor.submit(time.sleep, 1.5)
460 [CANCELLED_AND_NOTIFIED_FUTURE, SUCCESSFUL_FUTURE, future1],
466 self.assertEqual(set([future1]), pending)
469 future1 = self.executor.submit(mul, 2, 21)
474 [future1, future2, future3],
477 self.assertEqual(set([future1, future2]), finished)
481 future1 = self.executor.submit(divmod, 21, 0)
[all …]
|
| /external/python/cpython3/Lib/test/test_asyncio/ |
| D | test_proactor_events.py | 848 future1 = mock.Mock()
852 sock1.fileno(): future1,
858 self.assertTrue(future1.cancel.called)
|
| /external/conscrypt/repackaged/openjdk-integ-tests/src/test/java/com/android/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 257 final Future<byte[]> future1 = runAsync(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse() local
262 final byte[] serverSessionId1 = future1.get(); in test_SSLSocket_confirmSessionReuse()
|
| /external/conscrypt/openjdk-integ-tests/src/test/java/org/conscrypt/javax/net/ssl/ |
| D | SSLSocketVersionCompatibilityTest.java | 255 final Future<byte[]> future1 = runAsync(new SSLServerSessionIdCallable(server1)); in test_SSLSocket_confirmSessionReuse() local
260 final byte[] serverSessionId1 = future1.get(); in test_SSLSocket_confirmSessionReuse()
|
| /external/grpc-grpc-java/core/src/test/java/io/grpc/internal/ |
| D | ManagedChannelImplTest.java | 2768 ListenableFuture<Void> future1 = ClientCalls.futureUnaryCall(call1, null); in badServiceConfigIsRecoverable() local
2771 future1.get(); in badServiceConfigIsRecoverable()
|
| /external/protobuf/php/ext/google/protobuf/ |
| D | upb.h | 5231 void *future1;
5293 void *future1;
|
| /external/protobuf/ruby/ext/google/protobuf_c/ |
| D | upb.h | 644 void *future1; variable
|