private void runAsync(final Runnable asyncTask) {
        taskCounter.incrementAndGet();
        futures.add(CompletableFuture.runAsync(() -> {
            try {
                asyncTask.run();
            } finally {
                taskCounter.decrementAndGet();
            }
        }));
    }
To aid testing the generation without running {@link SetupSampleData}
stroom-app/src/test/java/stroom/test/SampleDataGenerator.java