Discussion :

[snyouf]

Bonjour,

Je travaille actuellement sur une appli multithreadé en utilisant un pool de thread du type ScheduledThreadPool();

executorService = java.util.concurrent.Executors.newScheduledThreadPool(corePoolSize);

puis

executorService.schedule((Runnable) job, (long) delay, TimeUnit.MILLISECONDS);

Ma question est la suivante, comment puis-je faire pour inclure la notion de priorité de mes threads ?

Pour le moment j'utilise une solution qui me semble peu clean, mais je n'en connais pas d'autre....

Merci de votre aide.

[feuxeu77]

Bonjour,

La méthode newScheduledThreadPool() peut accepter en deuxième argument une implémentation de ThreadFactory.

Libre à toi d'implémenter ThreadFactory comme tu le veux pour définir la priorité de tes Threads.

[snyouf]

Merci pour ta réponse.

J'ai bien tenté cette solution mais la création de Threads (et c'est l'intérêt d'un pool de threads) n'est faite qu'une fois pour plusieurs Runnable.
Or c'est en fonction du Runnable que j'ai à confier que dépend la priorité.

Il faudrait aller plus loin pour qui je puisse faire un truc du genre :

Code :

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

executorService.schedule((Runnable) job, (long) delay, TimeUnit.MILLISECONDS, job.getPriority'));

Mais il ne semble pas possible, de toute façon, de modifier la priorité d'un thread déjà créé ????!!!!!

[feuxeu77]

On peut changer la priorité d'un Thread.

Dans ton cas, le seul moyen immédiat que je vois est de faire comme dans le lien que tu as indiqué (changer la priorité, yield(), remettre l'ancienne priorité).

Pour faire plus propre :
- Soit tu fais ta propre implémentation de ExecutorService
- Soit tu fais un code du genre (juste histoire de factoriser) :

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
 
public abstract MyAbstractRunnable implements Runnable {
  public void run() {
    Thread t = Thread.currentThread();  
    int oldPriority = t.getPriority();  
    t.setPriority(getPriority());  
    Thread.yield();  
    run0();
    t.setPriority(oldPriority);  
  }
 
  protected abstract int getPriority();
 
  protected abstract void run0();
}

Et ensuite tous tes tasks extends MyAbstractRunnable en surchargeant run0 et getPriority comme elles l'entendent.

[snyouf]

Ok, merci pour ton aide.