class AsyncSema {
   Executor threadPool;
   Queue input;
   int counter=M;

  // задача встает в очередь к семафору и забирает единицу ресурса
   synchronized void aquire(Runnable task) {
      if (counter==0) {
        input.add(task);
     } else {
        counter--;
        execute(task);
    }

  // ресурс освобождается и пропускает другую задачу
   synchronized void release() {
      if (M==0 && !input.isEmpty()) {
         execute(input.remove());
      } else {
         M++;
      }

   // чтобы задачи не забывали возвращать ресурс,
   // сделаем это за них
   private void execute(final Runnable task) {
      threadPool.execute(new Runnable(){
         try {
           task.run();
         } finally {
           release();
         }
      });
    }
     
    // теперь вместо threadPool.execute(task)
    // используем aSema.aquire(task);
}

   synchronized void release() {
      if (counter==0 && !input.isEmpty()) {
         execute(input.remove());
      } else {
         counter++;
      }