Discussion :

[Plumb]

Bonjour,

Je m'interroge sur LE moyen de sortir le plus proprement possible d'une boucle de lecture d'un flux avec la fonction ReadFile().

Dans mon cas, on va dire que j'ai N threads qui lancent chacun un exécutable (CreateProcess()) dont la sortie standard est redirigée vers un pipe. Ces N threads lancent un thread de lecture de ce pipe.

Comme précisé précédemment, pour lire le contenu du pipe, j'utilise la fonction ReadFile(), sur laquelle je boucle. Je pense ne pas pouvoir sortir de cette boucle en testant la valeur du paramètre DWORD nNumberOfBytesToRead, ni même en appelant PeekNamedPipe() pour tester LPDWORD lpTotalBytesAvail, parce que les exécutables lancés sont différents et il peut se passer plusieurs secondes avant l'écriture dans le pipe.

J'ai tenté de partager une variable entre chaque paire de threads, sans résultat. En fait, je pensais qu'en passant son adresse en paramètre aux threads enfants, et en la modifiant dans les threads parents une fois que l'exécutable aurait terminé son exécution, je pourrais retrouver ce changement de valeur dans les threads enfants et ainsi pouvoir les arrêter.
Bizarrement, je capte ce changement de valeur avec ce code :

Code :

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

1
2
3
4
5
6
 
while(1)
{
     if(marqueur == 0)
         break;
}

mais pas avec celui-ci :

Code :

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

1
2
3
4
5
6
7
8
9
10
 
while(1)
{
     if(ReadFile(/* paramètres */))
     {
           /* Traitements */
     }
     if(marqueur == 0)
         break;
}

Qu'est-ce que j'ai loupé ?

[bacelar]

MSDN
Section Pipes

http://msdn.microsoft.com/en-us/libr...67(VS.85).aspx

[Plumb]

Disons que je continue de rechercher.

[Plumb]

MSDN
Section Pipes

http://msdn.microsoft.com/en-us/libr...67(VS.85).aspx

En fait, que j'utilise le mode synchrone ou asynchrone, la fonction ReadFile() ne retourne plus au bout d'un moment.

Avec le mode synchrone, la fonction ne retournait plus rien, alors que par ailleurs je savais que tout n'avait pas été lu. C'est d'ailleurs pour cette raison que je parvenais pas à vérifier mon changement de valeur (mauvaise solution que j'avais évoqué auparavant).

Non, vraiment, je suis passé à côté de quelque chose.

If an anonymous pipe is being used and the write handle has been closed, when ReadFile attempts to read using the pipe's corresponding read handle, the function returns FALSE and GetLastError returns ERROR_BROKEN_PIPE.

Testé, et ReadFile() n'a pas retourné FALSE.

[Plumb]

Bonjour,

Je viens de tester diverses choses, sans succès...
Si je redirige le flux du pipe dans un fichier, tout le contenu du pipe est lu. En revanche, si je le redirige vers une socket, je ne lis pas tout. J'imagine qu'on pourrait facilement trouver tout cela normal, mais cet aspect me consterne.

Je vais donc formuler une nouvelle question, que je ne m'étais visiblement pas posée.

Quel est le bon procédé pour lire dans un pipe en temps réel pendant la complétion de son contenu ?

[bacelar]

Primo, vérifiez que votre pipe est mono-directionnel.
Secondo, à en croire cette discussion http://www.techreplies.com/developme...e-time-723238/, vous êtes bon pour les overlapped I/O.

Enfin, les pipes, c'est un peu trop old school.
Sockets ou middlewares orientés messages sont plus simples et plus fiables.

[Astraya]

<petite parenthèse>
thread + while(1) == "bad"

Les conditions de test devrais être dans la condition du while
</petite parenthèse>

[Obsidian]

Enfin, les pipes, c'est un peu trop old school.
Sockets ou middlewares orientés messages sont plus simples et plus fiables.

Euh… les sockets plus simples que les pipes, il faut le dire vite, quand même. Et s'ils ne sont pas moins fiables, ils ne le sont pas plus non plus (sous Unix, en tout cas. Sous Windows, je ne saurais dire).

[lionel84]

Bonjour,

J'ai une question concernant les thread, les méthodes d'une classe sont exécuté chacune par un thread ou il y a un Thread global qui exécute toutes les méthodes d'une classe ?

Merci.

[Emmanuel Deloget]

Bonjour,

J'ai une question concernant les thread, les méthodes d'une classe sont exécuté chacune par un thread ou il y a un Thread global qui exécute toutes les méthodes d'une classe ?

Merci.

Comprends pas la question. Les thread font ce qu'ils veulent. S'ils veulent exécuter des méthodes de classes, il n'y a rien qui les en empêche. Sauf indication contraire, une méthode appelée dans un thread est exécutée dans le contexte de celui-ci.