Передайте аргумент для запуска функции в scheduleWithFixedDelay

Question

Как передать функцию в метод run при вызове с использованием executor.scheduleWithFixedDelay

Например.

IntStream.range(0, 4)
.forEach(
    i -> executor.scheduleWithFixedDelay(this::runOnce, 0, 5000, TimeUnit.MILLISECONDS));

Итак, как я могу передать аргумент в runOnce. Например. если бы я хотел отправить я?

Answer 1

Независимо от того, что возвращает runOnce, вы можете изменить ссылку на метод на лямбду и передать в качестве аргумента i:

IntStream.range(0, 4).forEach(i -> { 
    executor.scheduleWithFixedDelay(() -> runOnce(i), 0, 5000, TimeUnit.MILLISECONDS);
});

Answer 2

Вы хотите, чтобы this::runOnce возвращал Runnable на основе i, поэтому, если вы хотите, чтобы runnable просто выводил i на консоль, класс выглядел бы так:

public class Blah {

    public void whatever() {
        ScheduledExecutorService scheduledExecutorService =
            Executors.newScheduledThreadPool(5);
        IntStream.range(0, 4).forEach(i -> {
            scheduledExecutorService.scheduleWithFixedDelay(runOnce(i),
                0, 5000, TimeUnit.MILLISECONDS);
        });
    }

    private Runnable runOnce(int i) {
        return () -> System.out.println(i);
    }
}