Searched refs:ecs (Results 1 – 3 of 3) sorted by relevance
65 final ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testSubmitNPE() local69 ecs.submit(c); in testSubmitNPE()80 final ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testSubmitNPE2() local84 ecs.submit(r, Boolean.TRUE); in testSubmitNPE2()95 final ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testTake() local98 ecs.submit(c); in testTake()99 Future f = ecs.take(); in testTake()109 final ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testTake2() local112 Future f1 = ecs.submit(c); in testTake2()113 Future f2 = ecs.take(); in testTake2()[all …]
80 ExecutorCompletionService ecs = new ExecutorCompletionService(executor); in testSecureRandomThreadSafety() local82 ecs.submit(new Callable<Void>() { in testSecureRandomThreadSafety()93 ecs.take().get(); in testSecureRandomThreadSafety()
156 ExecutorCompletionService<T> ecs = in doInvokeAny() local173 futures.add(ecs.submit(it.next())); in doInvokeAny()178 Future<T> f = ecs.poll(); in doInvokeAny()182 futures.add(ecs.submit(it.next())); in doInvokeAny()188 f = ecs.poll(nanos, NANOSECONDS); in doInvokeAny()194 f = ecs.take(); in doInvokeAny()