Mise en œuvre correcte de Java Future multithread

Question

Dans mon servlet, je tape plusieurs URL pour vérifier leur statut et retourner la réponse à l'utilisateur.

Frapper des requêtes multipaires prend beaucoup de temps: besoin de threads et de timings. Mais j'ai besoin de mes threads pour obtenir la réponse: utiliser Future pour cette raison.

Mon plan de code:

ExecutorService executor = Executors.newFixedThreadPool(10); 
Future<statusModel> future; 

for (Map.Entry<String, String> url : urls.entrySet()) 
{ 
    try 
    { 
     future = executor.submit(new CallableRequestStatus(url.getValue())); 
     status = (statusModel) future.get(5, TimeUnit.SECONDS); 
     results.add(status); 
    } 
    catch (InterruptedException | ExecutionException | TimeoutException e) 
    { 
     System.out.println("Error<checkServers>: Timeout OR "+e.getMessage()); 
    } 
} 
executor.shutdownNow(); 

Tous les résultats de ma classe appelable est à venir dans l'objet d'état que j'ajouter plus tard à un ArrayList. Mon problème ici est que mon approche me bloque d'exécuter tous les 10 threads en même temps. Je dois attendre 5 secondes pour obtenir mon objet d'état, puis passer à l'URL suivante.

Je pense que mon approche est défectueuse. J'ai essayé de regarder en ligne mais je ne pourrais trouver aucun exemple avec des objets faits sur commande et Arraylist impliqué.

Quelqu'un peut-il m'aider à corriger ma faute. Merci à l'avance

enfin mis à jour mon code (grâce à Sotirios Delimanolis et Kevin):

ExecutorService executor = Executors.newFixedThreadPool(20); 
List<Future<statusModel>> futures = new ArrayList<Future<statusModel>>(); 

for (Map.Entry<String, String> url : urls.entrySet()) 
{ 
    Future<statusModel> future = executor.submit(new CallableRequestStatus(url.getValue())); 
    futures.add(future); 
} 

ArrayList<statusModel> results = new ArrayList<statusModel>(); 
statusModel status; 

int i=0; 

for (Map.Entry<String, String> url : urls.entrySet()) 
{   
    try 
     { 
      status = (statusModel) futures.get(i).get(500, TimeUnit.MILLISECONDS); 
      // do some stuff with status and 

      if(status.getStatusCode()/100 == 2) 
       results.add(status); 
     } 
    catch (InterruptedException | ExecutionException | TimeoutException e) 
     { 
      System.out.println("Error<checkServers>: Timeout OR "+e.getMessage()); 
     } 
i++; 
} 

executor.shutdownNow(); 
System.out.println("Shutdown: "+executor.isShutdown()); 

Espoir pour quelqu'un son utile :)

Answer 1

Vous devez soumettre tout dès le départ, puis attendez séparément. Comme ci-dessous, la gestion des exceptions a été supprimée pour plus de clarté:

ExecutorService executor = Executors.newFixedThreadPool(10); 
List<Future<statusModel>> futures = new ArrayList<>(); 

for (Map.Entry<String, String> url : urls.entrySet()) 
{ 
    futures.add(executor.submit(new CallableRequestStatus(url.getValue()))); 
} 
for (Future<statusModel> f : futures) { 
    results.add((statusModel) f.get(5, TimeUnit.SECONDS)); 
}