Discussion :

[m3allem001]

Bonjour,

je développe un programme avec les threads, je veux utiliser les événemets pour
synchroniser l'accès des threads aux files d'attentes.
Est ce qu'il ya l'équivilant de setEvent et resetEvent de C++ en java?
S'il y en a une autre façon de le faire, c'est gentil de la présenter.

Merci.

[tchize_]

Il y a d'autres façons de faire en java. Par exemple, le package java.util.concurrent contient de BlockingQueue qui peuvent servir à mettre X thread en attente d'élément dans la queue, pour que l'un d'entre eux traite cet élément, et à mettre de l'autre coté Y thread qui remplissent cette queue et qui attendent d'avoir de la place dedans. Donc typiquement le problème des producteurs / consommateurs.

Dis nous exactement quel est le but recherché, et on te dira quelle structure java est adaptée à ça

[m3allem001]

En fait j'ai travaillé avec les BlockingQueue et le programme tourne. Le problème c'est que les threads consomment énormément de CPU, ça peut aller jusqu'à 75 % même plus.
Chaque classe thread contient la méthode run :

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
 
public void run()
{
while (true) {	
 
    ////traitement
 
}}

J'ai essayé d'ajouter un wait dans chaque thread pour ne pas boucler infiniment pour rien,

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
 
public void run()
{
while (true) {	
 
   while(queue.isEmpty()){
 
	synchronized (this) {
		try {
			this.wait();
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
 }
 
 
  ////traitement
 
}}

càd tant que la file queue est vide laisser le thread en sleep.
et je met queue.notify dans l'endroit où il y a remplissage de la file.
Mais CPU Usage reste élevé.

[tchize_]

Ce n'est pas du tout comme ça qu'on utilise une blockingqueue!! C'est comme ça qu'on consume, et tu n'a aucun besoin de tester si c'est vide :/

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
while(true){
   Element e = queue.take();
   // traiter e
}

Tout simplement.

Et coté producteur

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
while(true){
   Element e = creerElement();
   queue.put(e);
}

Tu n'a rien à faire (synchronized, wait notify) pour syncrhoniser tes thread, c'est la BlockingQueue qui fais tous le travail dans put et take.

[m3allem001]

le block wait que j'ai ajouté c'est pas pour consume ou put mais pour tester si la file est vide ne pas entrer vainement dans la boucle et augmenter CPU Usage.
Mon problème ne consiste pas en put et consume , ça marche bien , mais plutôt comment minimiser l'utilisation de CPU.
Est ce que généralement l'utilisation des threads est gourmande en CPU ou quoi?

NB : queue.take() n'existe plus!!

[professeur shadoko]

NB : queue.take() n'existe plus!!

où ça?
take() existe bien!
par ailleurs comme l'a dit Cheese tu cherches à te compliquer la vie pour rien ...

[m3allem001]

désolé queue.take() n'existe pas pour Queue non pas pour BlockingQueue

Y a t'il un moyen pour minimiser CPU Usage, mon programme contient 5 threads qui accèdent à 5 BlockingQueue , le traitement prend bcq de temps.
Même si je désactive 4 threads et je travaille avec un , CPU Usage reste élevé,
je pense à cause du boucle while , car le thread reste toujours actif même si la file est vide.

[tchize_]

Mon problème ne consiste pas en put et consume , ça marche bien , mais plutôt comment minimiser l'utilisation de CPU.

Mais put et take minimisent déjà le cpu puisqu'ils se mettent déjà en pause ad vitam jusqu'à ce que respectivement il y aie de la place ou la liste soit vide.


Si ton cpu grimpe en flèche, c'est probablement parce que tes producteurs vont vite à produire et, du coup, tes consommateur n'arrêtent pas de traiter.


Montre nous le code que tu as créé simplement avec take et consume + le traitement et on te dira où est l'erreur. Les threads ne consomment pas en eux même du cpu, c'est TON code qui consomme du cpu. Si t'as 300 threads qui font un take sur un queue vide, t'aura 0% de cpu consommé. Si t'as 1 thread qui fait des take sur une queue toujours remplie, t'aura 100% de cpu consommé.

[m3allem001]

Si ton cpu grimpe en flèche, c'est probablement parce que tes producteurs vont vite à produire et, du coup, tes consommateur n'arrêtent pas de traiter.

c'est le cas, j'ai ajouté sleep pour quelques producteurs, il y a un peu de lenteur dans le traitement mais acceptable et CPU Usage aussi.

Je suis encore entrain de tester, c'est bon pour le moment.

Merci tous pour vos réponses.