Scheduler scheduler = new Scheduler();
scheduler.setThreadPool(threadPool);
scheduler.start();
class MyTask extends Task {
public void execute(TaskExecutionContext context) throws RuntimeException {
long startTime = System.currentTimeMillis();
long elapsedTime = System.currentTimeMillis() - startTime;
context.abort();
}
}
}
Scheduler scheduler = new Scheduler();
scheduler.start();