Method execute

src/main/java/com/volmit/adapt/util/Chunker.java:47–69

(Consumer<T> consumer, Callback<Double> progress, int progressInterval)

    }

    public void execute(Consumer<T> consumer, Callback<Double> progress, int progressInterval) {
        ChronoLatch cl = new ChronoLatch(progressInterval);
        Contained<Integer> consumed = new Contained<Integer>(0);
        executor = Executors.newFixedThreadPool(threads);
        int length = q.size();
        int remaining = length;

        while (remaining > 0) {
            int at = remaining;
            remaining -= (remaining > workload ? workload : remaining);
            int to = remaining;

            executor.submit(() ->
            {
                J.dofor(at, (i) -> i >= to, -1, (i) -> J.attempt(() -> consumer.accept(q.get(i))));
                consumed.mod((c) -> c += workload);
                J.doif(() -> progress != null && cl.flip(), () -> progress.run((double) consumed.get() / (double) length));
            });
        }

        executor.shutdown();
        J.attempt(() -> executor.awaitTermination(100, TimeUnit.HOURS));
    }
}