Specify the maximum amount of time a task should run

package stkparallelcomputingserversdk.howto;

import agi.parallel.client.ClusterJobScheduler;
import agi.parallel.client.IJobScheduler;
import agi.parallel.client.Job;
import agi.parallel.infrastructure.Task;

public class SpecifyHowLongTaskRuns {
    public static void main(String[] args) {
        try (IJobScheduler scheduler = new ClusterJobScheduler("localhost")) {
            scheduler.connect();

            Job job = scheduler.createJob();
            // For example, specify to let the tasks run for 20 seconds.
            job.setTaskExecutionTimeout(20_000);

            Task task = new LongRunningTask();
            job.addTask(task);

            job.submit();
            job.waitUntilDone();

            System.out.println("TaskStatus = " + task.getTaskStatus());
        }

        /*
         * The output of the application should resemble:
         * TaskStatus = TIMED_OUT.
         */
    }

    private static class LongRunningTask extends Task {
        @Override
        public void execute() {
            // For example, sleep forever. If TaskExecutionTimeout was not specified, this
            // task would run forever.
            try {
                Thread.sleep(Long.MAX_VALUE);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }
}