| /system/bt/osi/src/ |
| future.c | 21 #include "osi/include/future.h"
32 semaphore_t *semaphore; // NULL semaphore means immediate future
36 static void future_free(future_t *future);
62 void future_ready(future_t *future, void *value) {
63 assert(future != NULL);
64 assert(future->ready_can_be_called);
66 future->ready_can_be_called = false;
67 future->result = value;
68 semaphore_post(future->semaphore);
71 void *future_await(future_t *future) {
[all...] |
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| ListenableFutureTester.java | 35 * Used to test listenable future implementations.
42 private final ListenableFuture<?> future; field in class:ListenableFutureTester
45 public ListenableFutureTester(ListenableFuture<?> future) {
47 this.future = checkNotNull(future);
52 future.addListener(new Runnable() {
59 assertFalse(future.isDone());
60 assertFalse(future.isCancelled());
69 assertTrue(future.isDone());
70 assertFalse(future.isCancelled())
[all...] |
| AsyncSettableFutureTest.java | 36 /** Tests the initial state of the future. */
38 AsyncSettableFuture<Integer> future = AsyncSettableFuture.create(); local
39 assertFalse(future.isSet());
40 assertFalse(future.isDone());
41 assertFalse(future.isCancelled());
45 AsyncSettableFuture<Integer> future = AsyncSettableFuture.create(); local
46 assertTrue(future.setValue(42));
47 assertTrue(future.isSet());
48 // Later attempts to set the future should return false.
49 assertFalse(future.setValue(23))
59 AsyncSettableFuture<Object> future = AsyncSettableFuture.create(); local
79 AsyncSettableFuture<String> future = AsyncSettableFuture.create(); local
101 AsyncSettableFuture<Foo> future = AsyncSettableFuture.create(); local
[all...] |
| AbstractFutureTest.java | 48 AbstractFuture<String> future = new AbstractFuture<String>() { local
54 ExecutionException ee1 = getExpectingExecutionException(future);
55 ExecutionException ee2 = getExpectingExecutionException(future);
68 InterruptibleFuture future = new InterruptibleFuture(); local
69 assertTrue(future.cancel(false));
70 assertTrue(future.isCancelled());
71 assertTrue(future.isDone());
72 assertFalse(future.wasInterrupted());
73 assertFalse(future.interruptTaskWasCalled);
75 future.get()
83 InterruptibleFuture future = new InterruptibleFuture(); local
98 AbstractFuture<String> future = new AbstractFuture<String>() { local
111 final AbstractFuture<String> future = new AbstractFuture<String>() {}; local
[all...] |
| /external/testng/src/main/java/org/testng/internal/thread/ |
| FutureResultAdapter.java | 5 import java.util.concurrent.Future;
8 * A very reduced interface of <code>Future</code>.
13 Future<?> m_future;
15 public FutureResultAdapter(Future<?> future) {
16 m_future = future;
|
| /external/libnfc-nci/src/udrv/include/ |
| uipc.h | 37 #define UIPC_CH_ID_4 5 /* Future usage */
38 #define UIPC_CH_ID_5 6 /* Future usage */
39 #define UIPC_CH_ID_6 7 /* Future usage */
40 #define UIPC_CH_ID_7 8 /* Future usage */
41 #define UIPC_CH_ID_8 9 /* Future usage */
42 #define UIPC_CH_ID_9 10 /* Future usage */
43 #define UIPC_CH_ID_10 11 /* Future usage */
44 #define UIPC_CH_ID_11 12 /* Future usage */
45 #define UIPC_CH_ID_12 13 /* Future usage */
46 #define UIPC_CH_ID_13 14 /* Future usage *
[all...] |
| /external/libcxx/test/std/thread/futures/futures.unique_future/ |
| copy_assign.fail.cpp | 10 // <future>
12 // class future<R>
14 // future& operator=(const future&) = delete;
16 #include <future>
25 std::future<T> f0 = p.get_future();
26 std::future<T> f;
33 std::future<T> f0;
34 std::future<T> f;
42 std::future<T> f0 = p.get_future()
[all...] |
| copy_ctor.fail.cpp | 10 // <future>
12 // class future<R>
14 // future(const future&) = delete;
16 #include <future>
24 std::future<T> f0 = p.get_future();
25 std::future<T> f = f0;
31 std::future<T> f0;
32 std::future<T> f = f0;
39 std::future<T> f0 = p.get_future()
[all...] |
| move_assign.pass.cpp | 12 // <future>
14 // class future<R>
16 // future& operator=(future&& rhs);
18 #include <future>
27 std::future<T> f0 = p.get_future();
28 std::future<T> f;
35 std::future<T> f0;
36 std::future<T> f;
44 std::future<T> f0 = p.get_future()
[all...] |
| move_ctor.pass.cpp | 12 // <future>
14 // class future<R>
16 // future(future&& rhs);
18 #include <future>
27 std::future<T> f0 = p.get_future();
28 std::future<T> f = std::move(f0);
34 std::future<T> f0;
35 std::future<T> f = std::move(f0);
42 std::future<T> f0 = p.get_future()
[all...] |
| /ndk/sources/cxx-stl/llvm-libc++/libcxx/test/thread/futures/futures.unique_future/ |
| copy_assign.fail.cpp | 10 // <future>
12 // class future<R>
14 // future& operator=(const future&) = delete;
16 #include <future>
25 std::future<T> f0 = p.get_future();
26 std::future<T> f;
33 std::future<T> f0;
34 std::future<T> f;
42 std::future<T> f0 = p.get_future()
[all...] |
| copy_ctor.fail.cpp | 10 // <future>
12 // class future<R>
14 // future(const future&) = delete;
16 #include <future>
24 std::future<T> f0 = p.get_future();
25 std::future<T> f = f0;
31 std::future<T> f0;
32 std::future<T> f = f0;
39 std::future<T> f0 = p.get_future()
[all...] |
| move_assign.pass.cpp | 10 // <future>
12 // class future<R>
14 // future& operator=(future&& rhs);
16 #include <future>
25 std::future<T> f0 = p.get_future();
26 std::future<T> f;
33 std::future<T> f0;
34 std::future<T> f;
42 std::future<T> f0 = p.get_future()
[all...] |
| move_ctor.pass.cpp | 10 // <future>
12 // class future<R>
14 // future(future&& rhs);
16 #include <future>
25 std::future<T> f0 = p.get_future();
26 std::future<T> f = std::move(f0);
32 std::future<T> f0;
33 std::future<T> f = std::move(f0);
40 std::future<T> f0 = p.get_future()
[all...] |
| /external/jemalloc/msvc/projects/vc2015/test_threads/ |
| test_threads_main.cpp | 2 #include <future>
|
| /external/libgdx/gdx/src/com/badlogic/gdx/utils/async/ |
| AsyncResult.java | 22 import java.util.concurrent.Future;
27 private final Future<T> future;
field in class:AsyncResult
29 AsyncResult (Future<T> future) {
30 this.future = future;
35 return future.isDone();
42 return future.get();
|
| /external/skia/src/sfnt/ |
| SkIBMFamilyClass.h | 24 //6 reserved for future use
29 //11 reserved for future use
31 //13-15 reserved for future use
46 //9-14 reserved for future use
56 //3-14 reserved for future use
66 //3-14 reserved for future use
81 //8-14 reserved for future use
94 //6-14 reserved for future use
103 //2-14 reserved for future use
117 //7-8 reserved for future us
[all...] |
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| 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
45 * <p><b>Warning:</b> If the input future does not already implement {@code
46 * ListenableFuture}, the returned future will emulate {@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) {
[all...] |
| /prebuilts/eclipse/mavenplugins/tycho/tycho-dependencies-m2repo/org/eclipse/tycho/tycho-bundles-external/0.20.0/eclipse/plugins/ |
| org.eclipse.equinox.concurrent_1.1.0.v20130327-1442.jar | |
| /prebuilts/tools/common/m2/repository/org/eclipse/tycho/tycho-bundles-external/0.18.1/eclipse/plugins/ |
| org.eclipse.equinox.concurrent_1.1.0.v20130327-1442.jar | |
| /external/robolectric/v1/src/test/java/com/xtremelabs/robolectric/util/ |
| RobolectricBackgroundExecutorServiceTest.java | 10 import java.util.concurrent.Future;
47 Future<String> future = executorService.submit(runnable, "foo"); local
50 assertFalse(future.isDone());
54 assertTrue(future.isDone());
56 assertEquals("foo", future.get());
61 Future<String> future = executorService.submit(new Callable<String>() { local
69 assertFalse(future.isDone());
73 assertTrue(future.isDone())
[all...] |
| /external/guava/guava-testlib/src/com/google/common/util/concurrent/testing/ |
| AbstractListenableFutureTest.java | 29 import java.util.concurrent.Future;
44 protected ListenableFuture<Boolean> future; field in class:AbstractListenableFutureTest
49 // Create a latch and a future that waits on the latch.
51 future = createListenableFuture(Boolean.TRUE, null, latch);
62 * Constructs a listenable future with a value available after the latch
69 * Tests that the {@link Future#get()} method blocks until a value is
74 assertFalse(future.isDone());
75 assertFalse(future.isCancelled());
80 // Wait on the future in a separate thread.
85 assertSame(Boolean.TRUE, future.get())
[all...] |
| /system/bt/osi/test/ |
| future_test.cpp | 24 #include "osi/include/future.h"
39 future_t *future = future_new(); local
40 ASSERT_TRUE(future != NULL);
43 thread_post(worker_thread, post_to_future, future);
45 EXPECT_EQ(pass_back_data0, future_await(future));
51 future_t *future = future_new_immediate((void *)pass_back_data1); local
52 ASSERT_TRUE(future != NULL);
53 EXPECT_EQ(pass_back_data1, future_await(future));
|
| /toolchain/binutils/binutils-2.25/gas/testsuite/gas/aarch64/ |
| deprecated.l | 2 [^:]*:4: Warning: system register name 'spsr_svc' is deprecated and may be removed in a future release
3 [^:]*:5: Warning: system register name 'spsr_hyp' is deprecated and may be removed in a future release
|
| /external/guava/guava-testlib/test/com/google/common/util/concurrent/testing/ |
| TestingExecutorsTest.java | 29 import java.util.concurrent.Future;
48 ScheduledFuture<?> future = TestingExecutors.noOpScheduledExecutor().schedule( local
52 assertFalse(future.isDone());
73 List<Future<Boolean>> futureList = executor.invokeAll(
75 Future<Boolean> future = futureList.get(0); local
77 assertTrue(future.isDone());
79 future.get();
94 Future<Integer> future = TestingExecutors.sameThreadScheduledExecutor().schedule local
107 Future<?> future = TestingExecutors.sameThreadScheduledExecutor().submit(runnable); local
[all...] |
