test.java

    public TaskWrapper getNextTask() {
      TaskWrapper schTask = null;
      if(!scheduleQueue.isEmpty() && !checkingScheduled.get() && checkingScheduled.compareAndSet(false, true)) {
        while((schTask = scheduleQueue.peekFirst()) != null && schTask.getScheduleDelay() <= 0) {
          if(schTask.canExecute(schTask.getExecuteReference())) {
            scheduleQueue.remove(schTask);
            executeQueue.add(schTask);
          }
        }
        checkingScheduled.set(false);
      }
      TaskWrapper execTask = executeQueue.poll();
      if(execTask != null) {
        return execTask;
      }
      return schTask;
    }
  }