Développement Java
  1. Développement Java
  3. Étrange comportement de code concurrent
Intereting Posts
Pass-by-value (SsortingngBuilder vs Ssortingng) Réduire les instructions if-else en Java Comment Java implémente-t-il le pooling de chaînes? Pourquoi les classes wrapper en Java sont-elles définitives? Cache d’hibernation en cluster avec ehcache: écriture non ssortingcte ou écriture ssortingcte Pourquoi les bytecodes Java permettant d’appeler des méthodes acquièrent-ils et publient-ils implicitement des moniteurs? Les API Java Servlet sont-elles rétrocompatibles? java juste des accolades Le meilleur moyen de mettre à jour certains champs d’un object détaché sur Hibernate? Implémentation BGN en Java Comment obtenir la liste d’atsortingbuts de ArrayList d’objects Existe-t-il une option de ligne de commande permettant de définir le niveau de journalisation par défaut en Java? Comparaison de deux fichiers csv en Java Android studio java.lang.NoClassDefFoundError: android.support.v4.app.NavUtilsJB Tableau multidimensionnel de longueur nulle

Étrange comportement de code concurrent

Je suis en train d’apprendre la concurrence de Java. Et je suis très surpris par la façon dont le code suivant se comporte. 

import java.util.concurrent.*; public class Exercise { static int counter = 0; static synchronized int getAndIncrement() { return counter++; } static class Improper implements Runnable { @Override public void run() { for (int i = 0; i < 300; i++) { getAndIncrement(); } } } public static void main(String[] args) { ExecutorService executorService = Executors.newFixedThreadPool(3); for (int i = 0; i < 300; i++) { executorService.submit(new Improper()); } executorService.shutdown(); System.out.println(counter); } }

Ne devrait-il pas sortir 90000 tout le temps? Au lieu de cela, le résultat diffère tout le temps.

  1. executorService.shutdown() n’attend pas la fermeture du service. Vous avez besoin d’un appel pour awaitTermination .

  2. vous accédez au counter partir de la méthode principale sans locking. Je pense que vous échapperiez de peu à une course de données si vous attendiez l’arrêt du service de l’exécuteur, mais sachez qu’en règle générale, vous devez synchroniser tous les access d’une variable partagée, pas seulement les écritures, pour que la visibilité soit garantie. Modèle de mémoire Java.

Vous devez vous assurer que toutes les tâches ont eu le temps de se terminer. Utiliser awaitTermination 

 public static void main(Ssortingng[] args) throws InterruptedException { ExecutorService executorService = Executors.newFixedThreadPool(3); for (int i = 0; i < 300; i++) { executorService.submit(new Improper()); } executorService.shutdown(); executorService.awaitTermination(2, TimeUnit.SECONDS); System.out.println(counter); }

Vous n’attendez pas que toutes vos tâches soumises soient terminées, voir le document javadoc pour ExecutorService.html # shutdown . Obtenir une sortie arbitraire à chaque fois est donc le résultat attendu.