java.util.concurrent: calcul des nombres premiers

Question

Je suis nouveau dans le paquet

Était-ce utile?

Nous faire parvenir

La solution

Comme il est actuellement écrit loopMT n'attend pas les tâches soumises à remplir.

Vous avez quelques options:

• Appel awaitTermination() à attendre pour tous les tests de primalité pour compléter, écrire les résultats System.out que vous faites actuellement.
• Changer l'interface de Runnable à Callable<Boolean> ou peut-être Callable<Map.Entry<Long, Boolean>> et utiliser service.invokeAll() (vous obtiendrez tous les résultats retournés à la fois.)
• stocker les résultats dans un Map synchronisé et lu lorsque tous les tests de primalité ont terminé
• La méthode ou de run envoyer les résultats à un BlockingQueue ou SynchronousQueue, la boucle de la méthode de loopMT aller chercher les résultats de la file d'attente et de les imprimer. Ceci est l'option que je préférerais.
• Utiliser une file d'attente indirectement, par l'intermédiaire d'un CompletionService.

Answer 1

Comme il est actuellement écrit loopMT n'attend pas les tâches soumises à remplir.

Vous avez quelques options:

• Appel awaitTermination() à attendre pour tous les tests de primalité pour compléter, écrire les résultats System.out que vous faites actuellement.
• Changer l'interface de Runnable à Callable<Boolean> ou peut-être Callable<Map.Entry<Long, Boolean>> et utiliser service.invokeAll() (vous obtiendrez tous les résultats retournés à la fois.)
• stocker les résultats dans un Map synchronisé et lu lorsque tous les tests de primalité ont terminé
• La méthode ou de run envoyer les résultats à un BlockingQueue ou SynchronousQueue, la boucle de la méthode de loopMT aller chercher les résultats de la file d'attente et de les imprimer. Ceci est l'option que je préférerais.
• Utiliser une file d'attente indirectement, par l'intermédiaire d'un CompletionService.

Answer 2

Comme System.out est une instance de PrintStream il est thread-safe. Il est donc très bien pour des exemples de formation. Mais généralement sortie de différents fils ne semble pas être une bonne idée pour moi. Il est préférable d'avoir fil de sortie dédié qui accepte les demandes de sortie de manière asynchrone.

Probablement, je préfère mis en œuvre Callable<Boolean> comme finnw suggéré, sinon je ne vois aucune raison en classe IsPrime sauf de la consommation CPU.

Answer 3

Étant donné que ce calcul est probablement lié CPU, il n'y a aucun avantage à courir plus de fils que vous avez des noyaux CPU. discussions supplémentaires après qui ne font qu'ajouter aux frais généraux.