Searched refs:futures (Results 1 – 10 of 10) sorted by relevance
92 std::vector<std::future<sp<TypeParam>>> futures; in TYPED_TEST() local94 futures.push_back( in TYPED_TEST()98 futures[0].wait(); in TYPED_TEST()99 sp<TypeParam> firstHal = futures[0].get(); in TYPED_TEST()106 futures[i].wait(); in TYPED_TEST()107 sp<TypeParam> currentHal = futures[i].get(); in TYPED_TEST()
43 std::array<std::future<pid_t>, 64> futures; in TEST() local44 for (int i = 0; i < futures.size(); i++) { in TEST()45 futures[i] = CommonPool::async([] { in TEST()50 for (auto& f : futures) { in TEST()108 std::array<std::future<void>, QUEUE_COUNT> futures; in TEST() local112 futures[i] = CommonPool::async([&] { in TEST()141 for (auto& f : futures) { in TEST()
45 std::future<char> futures[] = {ftl::yield('a'), ftl::yield('b')}; in TEST() local49 .then([&futures](size_t i) { return std::move(futures[i]); }); in TEST()
27 import androidx.concurrent.futures.CallbackToFutureAdapter;28 import androidx.concurrent.futures.CallbackToFutureAdapter.Completer;
25 import androidx.concurrent.futures.CallbackToFutureAdapter;
44 import androidx.concurrent.futures.CallbackToFutureAdapter;45 import androidx.concurrent.futures.CallbackToFutureAdapter.Completer;
35 import androidx.concurrent.futures.CallbackToFutureAdapter;
77 "androidx.concurrent_concurrent-futures",157 "androidx.concurrent_concurrent-futures",
47 // Currently use 0, 100, 200 and 255, values in between are reserved for futures.
195 List<ForkJoinTask<?>> futures = new ArrayList<>(); in parseZip() local197 futures.add(ForkJoinPool.commonPool().submit(() -> { in parseZip()227 futures.forEach(ForkJoinTask::join); in parseZip()