concurrent closuere

concurrent

  def concurrent(int count, Closure closure) {
    def values = []
    def futures = []

    ExecutorService executor = Executors.newFixedThreadPool(count)
    CyclicBarrier barrier = new CyclicBarrier(count)

    for (int i = 0; i < count; i++) {
      futures.add(executor.submit(new Callable() {
        public def call() throws Exception {
          barrier.await()
          closure.call()
        }
      }))
    }

    for (Future future : futures) {
      try {
        def value = future.get()
        values << value
      } catch (ExecutionException e) {
        values << e.cause
      }
    }

    return values
  }