probléme dans l'execution du Thread

Version imprimable

bonjour

j'ai crée une classe TestRunnable.java qui implémente de la interface Runnable

j'ai fait ce code dans un Thread
Code:

1 2 3 4 5 6 7 8 9 10 11 Thread t1=new Thread(new TestRunable("Rule-71",factory,ruleEngine)); Thread t2=new Thread(new TestRunable("Rule-72",factory,ruleEngine)); try { t1.join(); t2.join(); } catch(InterruptedException e) { System.out.println ("echec d'attendre les thread") ; } Thread t3=new Thread(new TestRunable("Rule-73",factory,ruleEngine)); Thread t4=new Thread(new TestRunable("Rule-74",factory,ruleEngine));
mais le temps d’exécution est plus grand par rapport a l’exécution du code sans Thread...
un autre probléme il'ya un warning il ne peut pas accéder a la fonction run du classe TestRunnable

12/03/2012, 16h42
thelvin

En même temps il y a plein de trucs que tu nous montres pas :
- L'appel à start() sur les threads
- Le constructeur de TestRunable et ce qu'il fait.
- run() de TestRunable et ce qu'il fait.

Citation:

mais le temps d’exécution est plus grand par rapport a l’exécution du code sans Thread...

Ben oui, les threads c'est pas une formule magique. Ça permet d'utiliser plusieurs cœurs de processeur au lieu d'un seul, dans le cas où il y a beaucoup de calcul parallélisable ou qu'on veut paralléliser.

Mais lancer des threads et les synchroniser, ça a un coût. Si le calcul parallèle ne compense pas ce coût, alors utiliser plusieurs threads en parallèle prend plus de temps qu'un seul thread en séquence.

Citation:

Envoyé par Etudiante_Ines

un autre probléme il'ya un warning il ne peut pas accéder a la fonction run du classe TestRunnable

T'es trop vague, on est pas dans ta tête, montre les choses, un peu.

oui c'est vrai désolé monsieur
bon j'ai fait

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
long temps1=System.currentTimeMillis();
Thread t1=new Thread(new TestRunable("Rule-71",factory,ruleEngine));
Thread t2=new Thread(new TestRunable("Rule-72",factory,ruleEngine));
t1.start(); t2.start();
try
{
t1.join(); t2.join();
}
catch(InterruptedException e) {
		 	        System.out.println ("echec d'attendre les thread") ;
		 	      } 
Thread t3=new Thread(new TestRunable("Rule-73",factory,ruleEngine));
Thread t4=new Thread(new TestRunable("Rule-74",factory,ruleEngine));
t3.start(); t4.start();
long temps2=System.currentTimeMillis() - temps1;

mon but c'est d'optimiser le temps d'exécution

le constructeur de la classe TestRunable.java
private SWRLFactory factory;

Code:

1
2
3
4
5
6
7
8
private String ruleName;
	private SWRLRuleEngine ruleEngine ;
	public TestRunable(String ruleName, SWRLFactory factory, SWRLRuleEngine ruleEngine)
	{
		this.ruleName=ruleName;
		this.factory=factory;
		this.ruleEngine=ruleEngine;
	}

et la methode run

Code:

1
2
3
4
5
6
7
8
9
10
11
12
public void run()
	{
		try
		{
			factory.getImp(ruleName).enable();
		        ruleEngine.infer();
		}
		catch(Throwable e)
		{	
			e.printStackTrace();
		}
	}

et il y a un warning au niveau l'instruction

Code:

ruleEngine.infer();

(Unknown Source)

12/03/2012, 18h38
tchize_

Et c'est quoi ce warning?

Pour le reste du code, ben faut voir ce qui se passe dans ce enable. Mais a priori tu parallélise un code déjà rapide, du coup l'exécution en parallèle rajoute la surcharge de synchronisation et de création des thread bien supérieur au temps des threads individuel.

Aussi, tu ne nous dit pas comment tu mesure tes performances :)

De toutes façons, on ne parallélise que si c'est rentable. Tout n'est pas rentable à paralléliser.