luca.java

public static void main(String[] args) {
      final int parallelism = 8;
      final ExecutorService executor = Executors.newFixedThreadPool(parallelism);
      final CyclicBarrier started = new CyclicBarrier(parallelism);
      final Callable<Long> task = () -> {
         started.await();
         final Thread current = Thread.currentThread();
         long executions = 0;
         while (!current.isInterrupted()) {
            //quello che deve fare sul DM
            executions++;
         }
         return executions;
      };
      final ArrayList<Future<Long>> tasks = new ArrayList<>(parallelism);
      for (int i = 0; i < parallelism; i++) {
         tasks.add(executor.submit(task));
      }
      executor.shutdown();
      Runtime.getRuntime().addShutdownHook(new Thread(() -> {
         tasks.forEach(future -> future.cancel(true));
      }));
   }

OMG this code is amazing