public static <T> void exec(Runnable run, CompletableFuture<T> cf, Logger logger, String name) {
        try {
            run.run();
        } catch (Throwable ex) {
            logger.error("{} run with unexpected exception", name, ex);
            cf.completeExceptionally(ex);
        }
    }
Catch exceptions as a last resort to avoid unresponsiveness.
s3stream/src/main/java/com/automq/stream/utils/FutureUtil.java