Mejorar la Concurrencia en Java: Mejoras Clave en la API CompletableFuture

La clase CompletableFuture se introdujo en Java 8 para representar el Future que puede completarse estableciendo su valor y estado explícitamente. Puede usarse como java.util.concurrent.CompletionStage. Soporta funciones y acciones dependientes que se disparan al completarse el future. En Java 9, la API CompletableFuture se ha mejorado aún más. A continuación se muestran los cambios relevantes hechos a la API.

• Soporte para retrasos y timeouts.
• Mejor soporte para subclases.
• Nuevos métodos de fábrica añadidos.

Soporte para Retrasos y Timeouts

public CompletableFuture<T> completeOnTimeout(T value, long timeout, TimeUnit unit)

Este método completa este CompletableFuture con el valor dado si no se completa de otra forma antes del timeout dado.

public CompletableFuture<T> orTimeout(long timeout, TimeUnit unit)

Este método completa excepcionalmente este CompletableFuture con una TimeoutException si no se completa de otra forma antes del timeout dado.

Mejor Soporte para Subclases

public Executor defaultExecutor()

Devuelve el Executor por defecto usado para métodos async que no especifican un Executor. Este método puede sobrescribirse en subclases para devolver un Executor que proporcione al menos un hilo independiente.

public <U> CompletableFuture<U> newIncompleteFuture()

Devuelve un nuevo CompletableFuture incompleto del tipo que será devuelto por un método CompletionStage. Las subclases de la clase CompletableFuture deberían sobrescribir este método para devolver una instancia de la misma clase que este CompletableFuture. La implementación por defecto devuelve una instancia de la clase CompletableFuture.

Nuevos Métodos de Fábrica

public static <U> CompletableFuture<U> completedFuture(U value)

Este método de fábrica devuelve un nuevo CompletableFuture que ya está completado con el valor dado.

public static <U> CompletionStage<U> completedStage(U value)

Este método de fábrica devuelve un nuevo CompletionStage que ya está completado con el valor dado y soporta solo los métodos presentes en la interfaz CompletionStage.

public static <U> CompletionStage<U> failedStage(Throwable ex)

Este método de fábrica devuelve un nuevo CompletionStage que ya está completado excepcionalmente con la excepción dada y soporta solo los métodos presentes en la interfaz CompletionStage.