Java: запланированные задачи

Question

У меня есть 2 задачи - Задача A и Задача B. Задача A должна выполняться первой, и по завершении я хочу запустить свою периодическую задачу B, которая продолжает выполнять задачу, пока она не станет успешной.Как я могу реализовать это в Java?Я смотрел на запланированные сервисы выполнения, но, похоже, они основаны скорее на времени, чем на состоянии задачи.

Answer 1

Вот один из способов:

import java.util.concurrent.*;

public class ScheduledTasks {
    public static void main(String[] args) {
        ScheduledExecutorService executorService = Executors.newScheduledThreadPool(3);
        FollowupTask followupTask = new FollowupTask(executorService);
        FirstTask firstTask = new FirstTask(followupTask, executorService);
        executorService.submit(firstTask);
    }

    static class FirstTask implements Runnable {
        private FollowupTask followup;
        private ScheduledExecutorService executorService;

        FirstTask(FollowupTask followup, ScheduledExecutorService executorService) {
            this.followup = followup;
            this.executorService = executorService;
        }

        @Override
        public void run() {
            System.out.println("First task: counting to 5");
            for (int i = 1; i <= 5; i++) {
                sleep(1000);
                System.out.println(i);
            }
            System.out.println("All done! Submitting followup task.");
            executorService.submit(followup);
        }
    }

    static class FollowupTask implements Runnable {
        private int invocationCount = 0;
        private ScheduledExecutorService executorService;

        public FollowupTask(ScheduledExecutorService executorService) {
            this.executorService = executorService;
        }

        @Override
        public void run() {
            invocationCount++;
            if (invocationCount == 1) {
                System.out.println("Followup task: resubmit while invocationCount < 20");
            }
            System.out.println("invocationCount = " + invocationCount);
            if (invocationCount < 20) {
                executorService.schedule(this, 250, TimeUnit.MILLISECONDS);
            } else {
                executorService.shutdown();
            }
        }
    }

    static void sleep(long millis) {
        try {
            Thread.sleep(millis);
        } catch (InterruptedException e) {
            throw new IllegalStateException("I shouldn't be interrupted!", e);
        }
    }
}