Modèles avancés de threading

Optimiser son code en Java

Pavlos Kosmetatos

Lead Engineer @Wealthyhood

Principes des pools de threads

Créer un thread coûte cher !

Pools de threads :

Réutilisent les threads existants
Contrôlent le nombre de threads concurrents
Sont gérés via l'interface ExecutorService

Créer des pools de threads

// Pool fixe de 4 threads
ExecutorService fixedPool = Executors.newFixedThreadPool(4);


// Pool mis en cache qui grandit selon le besoin
ExecutorService cachedPool = Executors.newCachedThreadPool();


// Exécuteur mono-thread
ExecutorService singleExecutor = Executors.newSingleThreadExecutor();

Soumettre des tâches

ExecutorService executor = Executors.newFixedThreadPool(4);

// Soumettre une tâche sans valeur de retour
executor.execute(() -> System.out.println("Simple task"));

// Soumettre une tâche avec valeur de retour (Callable)
Future<Integer> future = executor.submit(() -> {
    Thread.sleep(1000);
    return 42;
});

// Récupérer le résultat depuis Future (bloque jusqu'à achèvement)
int result = future.get();

Arrêter les exécuteurs

// Demander l'arrêt, tout en laissant finir les tâches en cours
executor.shutdown();


// Attendre la terminaison (avec délai)
boolean terminated = executor.awaitTermination(5, TimeUnit.SECONDS);


// Forcer l'arrêt immédiat, en annulant les tâches en cours
executor.shutdownNow();

Le completable future

CompletableFuture
Fait partie de l'API de concurrence depuis Java 8
Approche moderne de la programmation asynchrone
Peut être complété manuellement ou via une Function
Permet d'enchaîner des opérations avec des callbacks
Fonctionne avec ou sans pools de threads explicites

Créer des completable futures

// Exécuter async avec l'exécuteur par défaut
CompletableFuture<Void> runAsync = 
    CompletableFuture.runAsync(() -> performTask());


// Fournir async avec un exécuteur personnalisé
ExecutorService executor = Executors.newCachedThreadPool();
CompletableFuture<String> supplyAsync = 
    CompletableFuture.supplyAsync(() -> fetchData(), executor);

Enchaîner des opérations

CompletableFuture<String> future = CompletableFuture
    .supplyAsync(() -> fetchUserData(userId))
    .thenApply(data -> extractUsername(data))
    .exceptionally(ex -> "Unknown user");

// Accéder au résultat quand il est prêt
future.thenAccept(result -> System.out.println(result));

Passons à la pratique !

Optimiser son code en Java