gistfile1.txt

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.ScheduledFuture;
import java.util.concurrent.TimeUnit;

public class DelayedScheduleTest {

  private static final int TASKS_NUMBER = 100;
  private ScheduledExecutorService executor;
  private ScheduledFuture<?> scheduledFuture;
  private Executor singleExecutor;

  public DelayedScheduleTest() {
    executor = Executors.newSingleThreadScheduledExecutor();
    singleExecutor = Executors.newSingleThreadExecutor();
  }

  private void execute() {
    for (int i = 0; i < TASKS_NUMBER; i++) {
      System.out.println("fire runnable: " + i);
      scheduleRunnable(i);
    }
  }

  private void scheduleRunnable(int i) {
    singleExecutor.execute(() -> {
      if (scheduledFuture != null) {
        scheduledFuture.cancel(false);
      }
      scheduledFuture = executor.schedule((Runnable) () -> System.out.println("runnable: " + i), 5,
          TimeUnit.SECONDS);
    });
  }

  public static void main(String[] args) {
    DelayedScheduleTest delayedScheduleTest = new DelayedScheduleTest();
    delayedScheduleTest.execute();
  }
}