Comment utiliser CompletableFuture pour implémenter la programmation simultanée asynchrone en Java ?

Utilisez CompletableFuture pour implémenter la programmation simultanée asynchrone en Java : Créez un CompletableFuture : créez un CompletableFuture via CompletableFuture.supplyAsync(), qui reçoit une méthode sans paramètre en tant que paramètre et renvoie une valeur. Gestion des situations d'achèvement : utilisez les méthodes whenComplete(), thenApply(), thenAccept(), exceptionnellement() et handle() pour gérer les situations d'achèvement de tâche, d'exception et d'annulation. Combinaison de CompletableFutures : chaînez deux CompletableFutures à l'aide de la méthode thenCompose(). Cas pratique : montre comment utiliser CompletableFuture pour obtenir une liste d'utilisateurs de la base de données en parallèle et obtenir les détails de chaque utilisateur depuis une API distante.

Comment utiliser CompletableFuture pour implémenter la programmation simultanée asynchrone en Java ?

Introduction

CompletableFuture est une classe utilitaire de concurrence introduite dans Java 8 qui vous permet d'exécuter des tâches de manière asynchrone et de gérer leur achèvement. Il offre un moyen plus élégant et simplifié de gérer la concurrence que les threads traditionnels.

Utilisation de base

Pour créer un CompletableFuture, vous pouvez utiliser la méthode CompletableFuture.supplyAsync(), qui accepte un Fournisseur comme paramètre. Le fournisseur est une méthode sans paramètres et renvoie une valeur.

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> "Hello");

Gestion de l'achèvement

L'une des principales caractéristiques de CompletableFuture est la capacité de gérer l'achèvement des tâches. Il fournit une variété de méthodes pour gérer les situations d'achèvement, d'exception et d'annulation :

• whenComplete() : exécute l'action spécifiée une fois la tâche terminée, que l'achèvement soit réussi ou non. whenComplete()：在任务完成后执行指定的动作，无论是否完成成功。
• thenApply()：在任务成功完成后执行指定的函数并返回一个新值。
• thenAccept()：在任务成功完成后执行指定的消费者。
• exceptionally()：在任务失败后执行指定的异常处理程序并返回一个新值。
• handle()：在任务完成后执行指定的函数，无论任务是否完成成功，并返回一个新值。

组合 CompletableFuture

CompletableFuture 可以组合起来创建更复杂的并行任务。例如，您可以使用 thenCompose()

thenApply() : exécute la fonction spécifiée et renvoie une nouvelle valeur une fois la tâche terminée avec succès.

thenAccept() : exécute le consommateur spécifié une fois la tâche terminée avec succès.

exceptionally() : exécute le gestionnaire d'exceptions spécifié et renvoie une nouvelle valeur après l'échec de la tâche.

handle() : exécute la fonction spécifiée une fois la tâche terminée, que la tâche soit terminée avec succès ou non, et renvoie une nouvelle valeur.

• Combining CompletableFutures

CompletableFutures peut être combiné pour créer des tâches parallèles plus complexes. Par exemple, vous pouvez utiliser la méthode thenCompose() pour enchaîner deux CompletableFutures :

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> 1);
CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> 2);

future1.thenCompose(x -> future2.thenApply(y -> x + y));

Cas pratique🎜🎜🎜Supposons que nous ayons les tâches suivantes qui doivent être exécutées en parallèle : 🎜🎜🎜 Obtenez de la liste des utilisateurs de la base de données 🎜🎜 Obtenez les détails de chaque utilisateur à partir de l'API distante 🎜🎜🎜 Nous pouvons utiliser CompletableFuture pour y parvenir : 🎜

CompletableFuture<List<User>> futureUsers = CompletableFuture.supplyAsync(() -> getUsersFromDatabase());

CompletableFuture<Map<Integer, UserDetail>> futureDetails = CompletableFuture.supplyAsync(() -> {
    List<User> users = futureUsers.get();
    return getUsersDetailsFromApi(users);
});

CompletableFuture<List<User>> combinedFuture = futureUsers.thenCombine(futureDetails, (users, details) -> {
    for (User user : users) {
        user.setDetails(details.get(user.getId()));
    }
    return users;
});

🎜 Cet exemple montre comment utiliser CompletableFuture pour obtenir des données de différentes sources en parallèle et les combiner. 🎜

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!