Discussion :

[plishty]

Bonjour à tous,

Voila je rencontre un problème dans un programme en C#.
J'ai un Thread qui tourne qui attend des messages depuis un NamedPipe, en client donc.
Seulement si j'essaye de fermer mon application le thread continue de tourner jusqu'au prochain message avant de quitter.

Code :
Fonction qui lance l'écoute :

Code :

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

1
2
3
4
5
private void EcouteNamedPipe()
{
     mobjThreadTube = new Thread(tubeNotif.Ecoute);
     mobjThreadTube.Start();
}

Fonction qui arrête l'écoute :

Code :

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

1
2
3
4
5
6
7
private void ArreteEcouteNamedPipe()
{
     if (mobjThreadTube != null)
     {
          tubeNotif.Stoppe();       
     }
}

Classe tubeNotif:
Fonction d'écoute tubeNotif.Ecoute:

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
public void Ecoute()
{
     mobjPipeClient = new NamedPipeClientStream(".", msNomTube, PipeDirection.InOut);
     mobjPipeClient.Connect(2000);
     StreamWriter objFluxEcrit = new StreamWriter(mobjPipeClient);
     objFluxEcrit.AutoFlush = true;
     objFluxEcrit.WriteLine(mnIdConnectTube); // permet l'identification du client pour le serveur
 
     objFluxLu = new StreamReader(mobjPipeClient);
     mbEcoute = true;
     while (mbEcoute == true) // boucle jusqu'à un appel à tubeNotif.Stoppe
     {
          string output = objFluxLu.ReadLine(); // bloque ici tant qu'il n'y a pas de nouveau message
          MessageBox.Show(output);
     }
}

Fonction d'arrêt tubeNotif.Stoppe:

Code :

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

1
2
3
4
5
6
7
8
9
public void Stoppe()
{
     mbEcoute = false;
     objFluxLu.Close();
     if (mobjPipeClient != null)
     {
          mobjPipeClient.Close(); 
     }
}

Seulement voila dans la fonction tubeNotif.Ecoute l'execution se bloque sur la ligne string output = objFluxLu.ReadLine(); tant qu'il n'y a pas de nouveau message. donc si j'appelle la fonction d'arrêt tubeNotif.Stoppe le thread reste actif.

Si quelqu'un à rencontrer ce type de problème et a trouvé une solution merci de la partager. Je reste ouvert aux suggestions

[KooKiz]

Il y a trois solutions qui me viennent :
- Tu laisses tomber le streamreader et tu lis de manière asynchrone avec mobjPipeClient.BeginRead (afin de ne pas bloquer ton thread)
- Tu appelles Thread.Abort pour stopper net ton thread (ne fonctionnera peut être pas s'il est bloqué sur un appel non managé)
- Ou un bon vieux Application.Exit(), ce n'est pas ce qu'il y a de plus élégant mais c'est efficace

Petite parenthèse, WCF simplifie énormément l'utilisation des NamedPipes. Tu devrais y jeter un œil, si tu as possibilité de l'utiliser dans ton application.

[plishty]

Merci KooKiz pour la réponse rapide.

[...]tu lis de manière asynchrone avec mobjPipeClient.BeginRead (afin de ne pas bloquer ton thread)

J'ai eu quelque soucis avec le mode asynchrone mais je vais réessayer ça.

Tu appelles Thread.Abort pour stopper net ton thread...

Pour ce qui est du thread.Abort j'ai déjà tester et le résultat est le même.

... un bon vieux Application.Exit(), ce n'est pas ce qu'il y a de plus élégant mais c'est efficace

Pour la solution "Application.Exit()" on va dire que j'aimerais m'en passer car il n'est pas à exclure que je pourrais avoir besoin d'arrêter l'écoute sans pour autant arrêter l'application.

Petite parenthèse, WCF simplifie énormément l'utilisation des NamedPipes. Tu devrais y jeter un œil, si tu as possibilité de l'utiliser dans ton application.

Je vais également regarder de ce coté.

Si vous avez d'autre idées... Merci d'avance

[tomlev]

Autre option : lance ton thread en background, comme ça il empêchera pas l'appli de se terminer.

Code :

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

1
2
3
4
5
6
private void EcouteNamedPipe()
{
     mobjThreadTube = new Thread(tubeNotif.Ecoute);
     mobjThreadTube.IsBackground = true;
     mobjThreadTube.Start();
}

[plishty]

Merci pour la réponse tomlev.

Autre option : lance ton thread en background, comme ça il empêchera pas l'appli de se terminer.

Code :

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

[...]mobjThreadTube.IsBackground = true;[...]

Effectivement l'application se ferme correctement.
Dans le cas ou je cherche juste à stopper l'écoute sans terminer l'application je ne suis pas sur que cela fonctionne cependant. Mais en faisant un mobjThreadTube.Suspend() cela fonctionne comme je veux.

Reste à tester si tout ca ne pose pas de problème au niveau du serveur du pipe.

Merci pour votre aide.