Parallélisme des données

salut,
dans mon application je fais le même traitement d'une façon itérative, à chaque itération sur une ligne de matrice.
ce que je veux c'est mettre en oeuvre du threading sur mes données, de telle façon que je puisse faire ce même traitement en des threads qui agissent sur des lignes et s’exécutent parallèlement chacun sur un processeur Différent.

qui peux m'aider SVP?

merci d'avance.

Tout dépend du nombre de lignes concernée, mais la solution basique consisterait à créer un thread par ligne. Pour cela, étendre la classe Thread, et dans la méthode run traiter la ligne. Ensuite appeler le start sur tous les threads créés.

Citation:

---

Envoyé par tchize_

Tout dépend du nombre de lignes concernée, mais la solution basique consisterait à créer un thread par ligne. Pour cela, étendre la classe Thread, et dans la méthode run traiter la ligne. Ensuite appeler le start sur tous les threads créés.

---

je ne pense pas que ca sera une bonne solution, vu que j'ai un grand nombre de ligne c preceque 6000. le traitement de chaque ligne prend preceque 10sec.

Citation:

---

Envoyé par hdioud.ferdaous

je ne pense pas que ca sera une bonne solution, vu que j'ai un grand nombre de ligne c preceque 6000. le traitement de chaque ligne prend preceque 10sec.

---

600 lignes par thread, 10 threads. Le principe reste le même :)

Citation:

---

Envoyé par tchize_

600 lignes par thread, 10 threads. Le principe reste le même :)

---

oui c vrai mais je ne veux pas faire l'appel de mes Thread manuellement. j'opte pour l'utilisation du framework qui fais l'affaire

bon je travailles en JEE avce des EJBs.
voici la classe qui va faire le multi-threading:

public class Transform extends RecursiveAction{

@EJB(name="CreateDecisionMatrix")
private CreateDecisionMatrix createDecisionMatrix;
private int min,max;

public Transform(int min, int max) {
this.min = min;
this.max = max;
}

@Override
protected void compute() {
if(max-min+1<=10)
process(min,max);
else
{
int milieu;
milieu=(max-min)/2;
Transform T1=new Transform(min,milieu);
Transform T2=new Transform(milieu+1,max);
T1.fork();
T2.fork();
}
}

public void process(int min,int max)
{
for(int i=min;i<=max;i++)
createDecisionMatrix.transform2(i);

}
le traitement je le réalise dans une servlet comme suit:

ForkJoinPool pool = new ForkJoinPool(groupSize);
Transform t = new Transform(3433,3450);
pool.invoke(t);
out.println("traitement fini");

ça marche pas!!! sachant qu'on m'affiche "traitement fini" sans avoir aucun traitement ou changement au niveau de mes tables

Pense à utiliser des balises codes pour rendre ton code lisible.

Comme il n'y a pas de join nulle part, il n'attends pas que T1 et T2 aient fini


Autre solution

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13

protected void compute() { if(max-min+1<=10) process(min,max); else { int milieu; milieu=(max-min)/2; Transform T1=new Transform(min,milieu); Transform T2=new Transform(milieu+1,max); invokeAll(T1,T2); } }

---

Note: exemple sortant directement de la javadoc hein..

Bonjour,

Juste une petite remarque par rapports aux Threads et à JEE.

La doc Sun/Oracle dit :

Citation:

---

What restrictions are imposed on enterprise beans?
[...]
* create or manage threads

---

Source ici.

Sur internet on peut lire partout qu'il ne faut pas utiliser de Thread en JEE...

Citation:

---

Envoyé par Gugelhupf

Sur internet on peut lire partout qu'il ne faut pas utiliser de Thread en JEE...

---

Oui, mais parfois, on n'a pas le choix ^^
Tu as déjà fait de l'authentification LDAP en j2EE? Je vais t'apprendre un truc, les librairie LDAP de sun créent des threads à crever sans te demander ton avis :aie:

Ce n'est pas qu'il ne faut pas faire de threads en J2EE, c'est qu'il faut être prudent quand on en fait: bien les nettoyer, ben les arrêter, s'assurer qu'ils ne saturent pas la machine (10 threads * 15 utilisateurs, ça commence à faire beaucoup), ....

Comme le fait remarquer Gugelhupf, la restriction est valable pour les EJBs.
On peut donc très bien créer des threads dans une servlet par exemple.
La question qui peut se poser, c'est, est-ce que ce long traitement doit se trouver dans un ejb ?

Bonjour,

J'ai effectué quelques recherches et j'ai découvert que pour Java EE 7, il existe une spécification JSR-236 qui permet d'utiliser les threads grâce à quelque chose (une API ou framework) qui ressemble au framework Executor.

Pour plus d'informations : ici.

En fait je n'en vois pas trop l'intérêt, on dirait vraiment que c'est du Executor avec des nouveaux noms d'interface.

PS: Désolé de squatter ce topic, mais je trouve que c'est un sujet intéressant les threads en JEE :oops: et merci pour l'info tchize_ :ccool: