Discussion :

[hdioud.ferdaous]

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.

[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.

[hdioud.ferdaous]

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.

[tchize_]

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

[hdioud.ferdaous]

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

[hdioud.ferdaous]

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