Transformation boucle while en action multi-thread [Résolu]

[Pedro4]

Bonjour,

je dois parcourir une collection pour créer un ArrayList avec chacun des éléments de la collection, en effectuant quelques opérations sur ces éléments.

Les opérations sont longues.

Je voudrais exécuter chaque item de la boucle en parallèle.

Ainsi pour chaque col.next je voudrais lancer un nouveau thread qui retourne le résultat et permet de l'ajouter à l'ArrayList.

La méthode se terminerait lorsque toute la collection a été parsée.

Existe-t-il un pattern permettant d'effectuer cet amélioration?

Mon code ressemble donc à cela:

Code :

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 
 
ArrayList al = ...;
 
while (col.next()) {
      String a = col.getString("a");
      int b = col.getInteger("b");
      String c = doSomething(a, b);
 
      al.add(dsr);
 
}
 
return al;

Comment faire pour que chaque item de la boucle soit effectué par un thread différent, et pour que la liste soit bien remplie à la fin?

[Mathieu.J]

C'est quoi la variable "dsr" ? Elle est crée à quel moment ?

[tchize_]

A supposer qu'il soit pertinent de paralléliser:

Enrober le code de calcul dans une classe X qui étends Runnable

Créer avant la boucle un ThreadPoolExecutor de taille donnée (à déterminer).

Pour chaque row rencontré, ajouter une nouvelle instance de X à l'executor (méthode execute)

après la boucle, attendre que l'executor aie fini le travail.

[Pedro4]

Envoyé par Mathieu.J

C'est quoi la variable "dsr" ? Elle est crée à quel moment ?

Je me suis trompé en adaptant mon code. La variable dsr ici est la String c.

[Pedro4]

Envoyé par tchize_

A supposer qu'il soit pertinent de paralléliser:

Enrober le code de calcul dans une classe X qui étends Runnable

Créer avant la boucle un ThreadPoolExecutor de taille donnée (à déterminer).

Pour chaque row rencontré, ajouter une nouvelle instance de X à l'executor (méthode execute)

après la boucle, attendre que l'executor aie fini le travail.

Merci,

effectivement c'est la logique des threads.
Je ne suis pas sûr qu'il soit pertinent de paralléliser. Peut-être que je vais laisser cela pour le moment et revenir dessus quand j'aurai plus d'information.
Je m'attendais à trouver un petit pattern, mais en fait ma question est tellement générale que je ne crois pas qu'il en existe de si générique.

[Pedro4]

bon, comme dit ci-dessous, il faut tout d'abord vérifier si c'est pertinent de sérialiser... et malheureusement je n'arrive pas à déterminer cela pour le moment (surtout par manque de temps de réflexion en fait).
Ayant pu grandement optimiser ma boucle par ailleurs, je ne vais pas utiliser les threads pour le moment.

Je passe quand même la question à résolue car l'architecture demandée est en fait expliquée dans tous les tutoriels sur les threads, et il s'avère que ma question était donc mal posée.

Merci!