ScheduledExecutorServiceTest

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

public class ScheduledExecutorServiceTest {

    // <editor-fold desc="Fields">

    private ScheduledExecutorService service;

    // <editor-fold>

    // <editor-fold desc="Constructor">

    public ScheduledExecutorServiceTest() {
        service = Executors.newScheduledThreadPool(Runtime.getRuntime().availableProcessors());

        System.out.println(String.format("Service created with %d processor(s).", Runtime.getRuntime().availableProcessors()));
    }

    // <editor-fold>

    // <editor-fold desc="Public">

    public void run() {
        int max = 10;
        long start = System.currentTimeMillis();

        for (int i = 0; i < max; i++) {
            Runnable task = () -> { System.out.println(String.format("%s: %s", Thread.currentThread().getName(), System.currentTimeMillis() - start)); };

            service.scheduleWithFixedDelay(task, 0, 300, TimeUnit.MILLISECONDS);

            i++;

            System.out.println(String.format("Iteration %d of %d.", i, max));
        }
    }

    // </editor-fold>

    public static void main(String[] args) {
        ScheduledExecutorServiceTest program = new ScheduledExecutorServiceTest();

        program.run();
    }
}