Searched refs:mFutures (Results 1 – 4 of 4) sorted by relevance
42 private final List<CompletableFuture> mFutures = Arrays.asList(new CompletableFuture<>(), field in CancelAllFuturesRuleTest.CheckFutureStatusRule57 assertThat(mFutures.get(0).isDone()) in apply()59 assertThat(mFutures.get(0).isCancelled()) in apply()62 assertThat(mFutures.get(0).isCancelled()) in apply()65 assertThat(mFutures.get(1).isCancelled()) in apply()73 return mFutures.get(idx);77 assertThat(mFutures.get(0).complete(null))
44 private final List<MockScheduledFuture<?>> mFutures = new ArrayList<>(); field in MockScheduledExecutorService52 ImmutableList<MockScheduledFuture<?>> futuresCopy = ImmutableList.copyOf(mFutures); in fastForwardTime()53 mFutures.clear(); in fastForwardTime()61 mFutures.add(future); in fastForwardTime()72 return mFutures; in getFutures()87 mFutures.add(future); in schedule()234 return mFutures.remove(this); in cancel()244 return !mFutures.contains(this); in isDone()
175 std::string, std::future<status_t>>> mFutures; // GUARDED_BY(mLock); member in android::AudioFileHandler::ThreadPool369 if (mFutures.size() >= mThreadPoolSize) { in launch()370 for (auto it = mFutures.begin(); it != mFutures.end();) { in launch()376 it = mFutures.erase(it); in launch()383 if (mFutures.size() < mThreadPoolSize) { in launch()385 mFutures.emplace_back(name, std::async(std::launch::async, func)); in launch()
357 private final List<CompletableFuture<CreateAppDataResult>> mFutures = new ArrayList<>(); field in Installer.Batch374 mFutures.add(future); in createAppData()399 final CompletableFuture<CreateAppDataResult> future = mFutures.get(i + j); in execute()