src/main/java/pl/edu/mimuw/cloudatlas/agent/AgentUtils.java


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

package pl.edu.mimuw.cloudatlas.agent;

import pl.edu.mimuw.cloudatlas.agent.messages.TimerSchedulerMessage;
import pl.edu.mimuw.cloudatlas.agent.modules.RecursiveScheduledTask;
import pl.edu.mimuw.cloudatlas.agent.modules.TimerScheduledTask;

import java.util.function.Supplier;

public class AgentUtils {

    public static void startRecursiveTask(Supplier<TimerScheduledTask> taskSupplier, long period, EventBus eventBus) {
        TimerScheduledTask timerTask = new RecursiveScheduledTask(period, taskSupplier);
        try {
            eventBus.addMessage(new TimerSchedulerMessage("", 0, "", period, 0, timerTask));
        } catch (InterruptedException e) {
            System.out.println("Interrupted while starting queries");
        }
    }
}