AsioVisitor.java

/**
   * handles SslEngine state NEED_TASK.creates a phaser and launches all threads with invokeAll  
   *
   * @param key 
   * @param sslEngine
   * @param executorService
   * @return
   */
  public static int delegateTasks(final SelectionKey key,   SSLEngine sslEngine, ExecutorService executorService) {
    final int origOps = key.interestOps();
    List<Callable<Void>> runnables = new ArrayList<>();
    final AtomicReference<Phaser> phaser = new AtomicReference<>( );

    Runnable t;
    while (null != (t = sslEngine.getDelegatedTask())) {

      final Runnable finalT1 = t;
      runnables.add(new Callable<Void>() {
        @Override
        public Void call() throws Exception {
           finalT1.run();
          phaser.get().arriveAndAwaitAdvance();
          return null;
        }
      });
    }

    runnables.add(new Callable<Void>() {
      @Override
      public Void call() throws Exception {
        ;
        Phaser phaser1 = phaser.get();
        phaser1.awaitAdvanceInterruptibly(phaser1.arrive());
        key.interestOps(origOps);
        return null;
      }
    });
    try {
      key.interestOps(0);
      phaser.set(new Phaser(runnables.size()  ));

      executorService.invokeAll(runnables);

    } catch (InterruptedException e) {
      e.printStackTrace();
    }


    return 0;
  }