public class ScheduledTaskCommandExecutor extends ScheduledThreadPoolExecutor {
private final static TaskCommandThreadFactory factory;

  public ScheduledTaskCommandExecutor(int corePoolSize) {
    super(corePoolSize, factory, new RejectionHandler());
    //setMaximumPoolSize(corePoolSize);
    //allowCoreThreadTimeOut(true);
    semaphore = new Semaphore(corePoolSize);
    setRemoveOnCancelPolicy(true);
    setKeepAliveTime(10, TimeUnit.MILLISECONDS);
  }

  static {
    factory = new TaskCommandThreadFactory();
  }

  @Override
  protected void afterExecute(Runnable r, Throwable t) {
    try {
      long endTime = System.nanoTime();
    } finally {
      super.afterExecute(r, t);
      //System.out.println(getTaskNameByFuture((Future) r) + " " + ConsoleProperties.Message.TASK_IS_COMPLETED.get());
      activeTask.remove(r);
      semaphore.release(1);
      purge();
    }
  }

public Future execute(TaskCommand command) throws RejectedExecutionException {
    if(getActiveCount() == getCorePoolSize()) {
      System.out.println(getActiveCount() + " " + getCorePoolSize());
      throw new RejectedExecutionException();
      //так же пробовал с  if(semaphore.tryAcquire()), освобождаю на 1 в afterExecute
    }
    factory.setCommand(command);
    return command.setFuture(schedule(command, command.getDelay(), TimeUnit.MILLISECONDS));
  }
}

private static class TaskCommandThreadFactory implements ThreadFactory {
    private TaskCommand command;

    public void setCommand(TaskCommand command) {
      this.command = command;
    }

@Override
//метод нормально вызывается до заполнения очереди, после удаления из заполненной одного таска, новый submit не вызывает это
public Thread newThread(Runnable r) {
Thread ret = new Thread(..some custom data from TaskCommand)
return ret;
}

private static class RejectionHandler implements RejectedExecutionHandler {
    @Override
    public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
      //todo log4j
      System.out.println(r.toString() + " : Rejected");
      throw new RejectedExecutionException();
    }
  }