Searched refs:workerFutures (Results 1 – 2 of 2) sorted by relevance
275 List<ListenableFuture<?>> workerFutures = new ArrayList<ListenableFuture<?>>(); in maxStreams() local277 workerFutures.add(threadpool.submit(new MaxStreamsWorker(i, simpleRequest))); in maxStreams()279 ListenableFuture<?> f = Futures.allAsList(workerFutures); in maxStreams()
119 private final List<ListenableFuture<?>> workerFutures = field in StressTestClient238 workerFutures.add(threadpool.submit(worker)); in runStressTest()248 ListenableFuture<?> f = Futures.allAsList(workerFutures); in blockUntilStressTestComplete()