Searched refs:awaiter (Results 1 – 3 of 3) sorted by relevance
373 ForkJoinTask a = p.submit(awaiter(done)); in testPollSubmission()374 ForkJoinTask b = p.submit(awaiter(done)); in testPollSubmission()375 ForkJoinTask c = p.submit(awaiter(done)); in testPollSubmission()392 ForkJoinTask a = p.submit(awaiter(done)); in testDrainTasksTo()393 ForkJoinTask b = p.submit(awaiter(done)); in testDrainTasksTo()394 ForkJoinTask c = p.submit(awaiter(done)); in testDrainTasksTo()579 final Callable<Void> awaiter = new CheckedCallable<Void>() { in testInterruptedSubmit() local587 Future<Void> future = p.submit(awaiter); in testInterruptedSubmit()
179 final Callable<Void> awaiter = new CheckedCallable<Void>() { in testInterruptedSubmit() local187 Future<Void> future = p.submit(awaiter); in testInterruptedSubmit()
793 public Runnable awaiter(final CountDownLatch latch) {