gistfile1.java

CompletableFuture.<Void>runAsync(replicationTask, replicationTaskExecutor)
    .thenAcceptAsync(aVoid -> {
        log.info("Repair of disk {} finished on node {}", diskId, membershipService.getSelfNode());
        semaphore.release();
    })
    .exceptionally(throwable -> {
        log.error("Can't repair cluster", throwable);
        semaphore.release();
        return null;
    });