Discussion :

[SuperNiKo]

Dans le cadre d 'un TP on doit créer un serveur FTP basique, jusque là rien de bien compliqué. Mais là où je galère un peu c 'est le thread pool... En effet on doit éviter que le serveur ne s' "effondre" sous un aflu de requête => donc là thread pool.

Un pti bout de code vaut mieux qu'un long discours

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
 
ThreadPoolExecutor pool = 
   new ThreadPoolExecutor(corePoolSize,
                        maximumPoolSize,
                        keepAliveTime,
                        timeUnit,
                        new SynchronousQueue<Runnable>());
 
while (true) {
   try {
      //sock est un ServerSocket déclaré précédement
      sockClientServeur = sock.accept();
      pool.execute(new FtpRequest(sockClientServeur,wdir));
   } catch (IOException e) {
      e.printStackTrace();
   }
}

Donc à chaque connexion sur le ServeurSocket, on balance le traitement dans un Runnable de type FtpRequest qui va tout gérer. Mais comment ça fonctionne dans le pool?

Je veux dire, le but du pool est -notamment- de garder une réserve de thread dans certaines limites pour éviter de les lancer (ce qui est couteux) . Donc après X connexion, c 'est ok j 'ai atteint le corePoolSize. Imaginons un des FtpRequest qui se termine -> il reste alors idle et n'est pas supprimé pour rester dans les bornes corePoolSize/maximumPoolSize. Une nouvelle connexion est établie et... il se passe quoi?

A) il lance un nouveau thread quand même : pas logique vu la doc
B) il remplace les paramètres du thread idle par les nouveaux? (aka il arrive à lui refiler la socket?!)
C) abracadabra?

je vous avoue que j'ai cherché longtemps mais rien trouvé

[ndp]

Salut,

...
A) il lance un nouveau thread quand même : pas logique vu la doc
B) il remplace les paramètres du thread idle par les nouveaux? (aka il arrive à lui refiler la socket?!)
C) abracadabra?
...

Tes objets FtpRequest sont instancies et partages par tous les threads, ce n'est pas forcement toujours le cas, mais ici oui.
Pour faire simple, la reponse est B) et le passage de parametre entre thread se fait via l'objet FtpRequest.

[SuperNiKo]

Question qui me vient à l esprit alors, est ce que c est utile de

Code :

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

pool.prestartAllCoreThreads();

?