Searched refs:ecs (Results 1 – 3 of 3) sorted by relevance
34 ExecutorCompletionService ecs = new ExecutorCompletionService(null); in testConstructorNPE() local45 ExecutorCompletionService ecs = new ExecutorCompletionService(e, null); in testConstructorNPE2() local55 ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testSubmitNPE() local58 ecs.submit(c); in testSubmitNPE()71 ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testSubmitNPE2() local74 ecs.submit(r, Boolean.TRUE); in testSubmitNPE2()87 ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testTake() local90 ecs.submit(c); in testTake()91 Future f = ecs.take(); in testTake()103 ExecutorCompletionService ecs = new ExecutorCompletionService(e); in testTake2() local[all …]
80 ExecutorCompletionService ecs = new ExecutorCompletionService(executor); in testSecureRandomThreadSafety() local82 ecs.submit(new Callable<Void>() { in testSecureRandomThreadSafety()93 ecs.take().get(); in testSecureRandomThreadSafety()
119 ExecutorCompletionService<T> ecs = in doInvokeAny() local136 futures.add(ecs.submit(it.next())); in doInvokeAny()141 Future<T> f = ecs.poll(); in doInvokeAny()145 futures.add(ecs.submit(it.next())); in doInvokeAny()151 f = ecs.poll(nanos, TimeUnit.NANOSECONDS); in doInvokeAny()157 f = ecs.take(); in doInvokeAny()