Comment utiliser invokeAll() pour permettre à tous de pool de threads font leur travail?

La façon dont une ExecutorService fonctionne, c'est que lorsque vous appelez invokeAll il attend pour toutes les tâches à effectuer:

Exécute les tâches, de retour d'une liste de Terme en tenant leur
le statut et les résultats lorsque tous les remplir. L'avenir.isDone() est vrai pour chaque
élément de la liste retournée. Noter qu'une tâche terminée pourrait avoir
résilié, soit normalement ou par la levée d'une exception. Les résultats de
cette méthode n'est pas défini si la collection donnée est modifiée alors que
cette opération est en cours.^Un(italiques ajoutés)

Ce que cela signifie, c'est que vos tâches sont tous fait, mais certains peuvent avoir jeté une exception. Cette exception est une partie de la Future - appel get provoque l'exception levée de nouveau enveloppé dans un ExecutionException.

De vous stacktrack

java.util.concurrent.ExecutionException: java.lang.NullPointerException at
java.util.concurrent.FutureTask$Sync.innerGet(Unknown Source) at
java.util.concurrent.FutureTask.get(Unknown Source) at 
                                ^^^ <-- from get

Vous pouvez voir que c'est effectivement le cas. L'une de vos tâches a échoué avec un NPE. Le ExecutorService attiré l'exception et de vous parler d'elle en jetant un ExecutionException lorsque vous appelez Future.get.

Maintenant, si vous voulez prendre tâches qu'ils terminent vous avez besoin d'un ExecutorCompletionService. Cela agit comme un BlockingQueue qui vous permettra de sondage pour des tâches comme et quand ils ont fini.

public static void main(String[] args) throws Exception {
    final ExecutorService executorService = Executors.newFixedThreadPool(10);
    final ExecutorCompletionService<String> completionService = new ExecutorCompletionService<>(executorService);
    executorService.submit(new Runnable() {
        @Override
        public void run() {
            for (int i = 0; i < 100; ++i) {
                try {
                    final Future<String> myValue = completionService.take();
                    //do stuff with the Future
                    final String result = myValue.get();
                    System.out.println(result);
                } catch (InterruptedException ex) {
                    return;
                } catch (ExecutionException ex) {
                    System.err.println("TASK FAILED");
                }
            }
        }
    });
    for (int i = 0; i < 100; ++i) {
        completionService.submit(new Callable<String>() {
            @Override
            public String call() throws Exception {
                if (Math.random() > 0.5) {
                    throw new RuntimeException("FAILED");
                }
                return "SUCCESS";
            }
        });
    }
    executorService.shutdown();
}

Dans cet exemple, j'ai une tâche qui demande take sur le ExecutorCompletionService qui obtient le Futures qu'ils seront disponibles puis-je soumettre des tâches à l' ExecutorCompletionService.

Cela vous permettra d'obtenir la tâche qui a échoué dès qu'il échoue, plutôt que d'avoir à attendre pour toutes les tâches à pas de réussir ensemble.

La seule complication est qu'il est difficile de dire à l'interrogation de fil que toutes les tâches sont effectuées que tout est maintenant asynchrone. Dans cet exemple, j'ai utilisé la connaissance que de 100 missions seront soumis, de sorte qu'il suffit d'interroger 100 fois. D'une manière plus générale serait de collecter les Futures de la submit méthode et une boucle au-dessus d'eux pour voir si tout est terminé.

OriginalL'auteur Boris the Spider

invokeAll est un blocage de la méthode. Cela signifie – JVM de ne pas passer à la ligne suivante jusqu'à ce que tous les fils sont terminés. Donc, je pense qu'il ya quelque chose de mal avec votre fil futur résultat.

System.out.println("name is:"+future.get(i).get().getName());

à partir de cette ligne, je pense qu'il y a certains contrats à terme n'avons pas de résultat et peut être nulle, de Sorte que vous devriez vérifier votre code, s'il y a des contrats à Terme null,le Cas échéant, obtenir un si avant cette ligne exécutée.

OriginalL'auteur Winston