public class SampleTask extends AbstractTask {
    private String name;

    public SampleTask(String name) {
        super();
        this.name = name;
    }

    @Override
    protected TaskResult run() {
        try {
            // do something fancy
            Thread.sleep((long) (1000));
        } catch (final InterruptedException e) {
            return new TaskResult(TaskResult.ERROR, e);
        }
        return new TaskResult(TaskResult.SUCCESS);
    }

    @Override
    protected void cancel() {
        // should cancel the task, but we ignore this for this example
    }

    public String getName() {
        return name;
    }
}

public class Main implements TaskEventListener<SampleTask> {
    public static void main(String[] argv) throws TaskException, InterruptedException {
        new Main().run();
    }

    private long startedAt;

    public void run() throws TaskException, InterruptedException {
        QueuedTaskRunner<SampleTask> taskRunner = new QueuedTaskRunner<SampleTask>();

        taskRunner.setTaskEventListener(this);      // retrieve callbacks from the taskrunners
        taskRunner.setNumberOfConcurrentTasks(3);   // allow 3 concurrent tasks at once

        startedAt = System.currentTimeMillis();
        for (int i = 0; i < 10; i++) {
            taskRunner.execute(new SampleTask("Foo Task " + i));
        }

        // wait for all tasks to complete
        taskRunner.join();
        
        // dispose the taskrunner
        taskRunner.dispose();
    }

    @Override
    public void taskComplete(SampleTask task, TaskResult result) {
        long time = System.currentTimeMillis() - this.startedAt;
        if (result.getStatus() == TaskResult.SUCCESS) {
            System.out.println("Task " + task.getName() + " completed successful after " + time + "ms");
        } else {
            System.out.println("Problem completing Task " + task.getName());
        }
    }
}