@rvansa I think it would be simpler to implement CompletionService directly, similar to ExecutorCompletionService, creating a FutureTask that overrides `done()` and updates the counters directly.