public void execute() {
        if (running.compareAndSet(false, true)) {
            final Executor executor = executorProvider.get();
            executor.execute(this::fetch);
        }
    }
The Stroom lifecycle service will try and fetch new tasks for execution.
stroom-job/stroom-job-impl/src/main/java/stroom/job/impl/DistributedTaskFetcher.java