Control task concurrency on agent

package stkparallelcomputingserversdk.howto;

import java.net.InetAddress;
import java.text.SimpleDateFormat;
import java.util.GregorianCalendar;

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

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

            Job job = scheduler.createJob();

            // Set ExclusiveExecution to true
            job.setExclusiveExecution(true);

            for (int i = 0; i < 3; ++i) {
                Task task = new OnlyTaskThatIsRunning();
                job.addTask(task);
            }

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

            SimpleDateFormat dateFormat = new SimpleDateFormat("MM/dd/yyyy HH:mm:ss aaa");
            for (int i = 0; i < 3; ++i) {
                Task task = job.getTasks().get(i);
                GregorianCalendar start = (GregorianCalendar) task.getProperty(TaskProperties.HOST_START_TIME);
                GregorianCalendar end = (GregorianCalendar) task.getProperty(TaskProperties.HOST_END_TIME);

                System.out.format("Task #%s ran on %s from %s to %s%n",
                        i + 1,
                        task.getResult(),
                        dateFormat.format(start.getTime()),
                        dateFormat.format(end.getTime()));
            }
        }

        /*
         * The output of the application should resemble:
         * Task #1 ran on MyComputerName from 2/28/2013 5:34:24 PM to 2/28/2013 5:34:29 PM
         * Task #2 ran on MyComputerName from 2/28/2013 5:34:29 PM to 2/28/2013 5:34:34 PM
         * Task #3 ran on MyComputerName from 2/28/2013 5:34:34 PM to 2/28/2013 5:34:39 PM
         */
    }

    public static class OnlyTaskThatIsRunning extends Task {
        @Override
        public void execute() {
            try {
                Thread.sleep(5_000);
                this.setResult(InetAddress.getLocalHost().getHostName());
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}