PipeStream en C# pour communication inter-threads ?

Version imprimable

27/06/2023, 23h20
bn0550

PipeStream en C# pour communication inter-threads ?

Bonjour,

Y a-til une classe .NET permettant d'avoir un Stream partagé entre 2 threads
- un qui écrit des données
- un qui lit les données

.. ce qui se fait en Java de cette manière

pin = new PipedInputStream();
pout = new PipedOutputStream((PipedInputStream)pin);

Merci
28/06/2023, 07h38
François DORIN
Bonjour,
presque la même chose :
- AnonymousPipeServerStream / AnonymousPipeClientStream
- NamedPipeServerStream / NamedPipeClientStream
Ces streams sont utilisables pour des communications interprocess, donc valable également pour des communications interthreads.
28/06/2023, 10h30
bn0550

Bonjour,

J'avais effectivement vu ces classes mais cela me paraissait lourd ?
Je vais essayer

Merci
28/06/2023, 16h56
Pol63

tout peut être partagé entre 2 threads, je ne vois pas pourquoi il faudrait quelque chose de spécial
même un event ca conviendrait surement
dans le pire des cas quelque chose avec un lock
28/06/2023, 17h08
François DORIN

Des accès concurrents nécessitent des précautions d'usage. Sinon, c'est une source de bogue plus ou moins fréquent extrêmement difficile à diagnostiquer.

Pour un stream, il faut quelque chose de spéciale, car les flux de lecture et d'écriture ne vont pas évoluer de la même manière. Même si on a un stream qui est à la fois accessible en lecture et en écriture (comme MemoryStream), mélanger une opération de lecture avec une d'écriture (sans même parler d'accès concurrents), c'est le meilleur moyen d'avoir un bazar monstre, car la lecture du flux va modifier la position courante, qui ne sera plus bonne pour l'écriture et vice-versa. Et dans le cas d'accès concurrents, un lock seul ne suffira pas, d'où la nécessite d'avoir une structure particulière.

Après, c'est un problème "classique" de producteur / consommateur. Est-ce que le stream est le plus adéquat ici ? Aucune idée, puisqu'on ne sait pas la nature des données qui transitent par le flux. Mais cette question sort du cadre de cette discussion.

Bonjour,

Voici les tests que je viens de réaliser.
Le second test ne fonctionne pas... avez vous une piste ?

Le but final est de rendre disponible ce qui est lu du serveur SSH comme input pour un autre traitement (CopyTo par exemple)

Ce premier test fonctionne sans les pipes

Code:

1
2
3
4
5
6
7
8
9
 
using (MemoryStream o = new MemoryStream())
            {                
                using (SftpFileStream pin = client.OpenRead("/toto/fichier.txt"))
                {
                    pin.CopyTo(o);
                }
                byte[] res = o.ToArray();
            }

Ce second exemple ne fonctionne pas, cela bloque au niveau du Join.

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
 
using (AnonymousPipeServerStream pipein = new AnonymousPipeServerStream(PipeDirection.In))
            {
                using (AnonymousPipeClientStream pipeout = new AnonymousPipeClientStream(PipeDirection.Out,
                    pipein.GetClientHandleAsString()))
                {
                    byte[] res;
                    Thread t = new Thread(() =>
                    {
                        using (MemoryStream x = new MemoryStream())
                        {
                            pipein.CopyTo(x);
                            res = x.ToArray();
                        }
                    });
                    t.Start();
 
                    using (SftpFileStream pin = client.OpenRead("/toto/fichier.txt"))
                    {
                        pin.CopyTo(pipeout);
                    }
 
                    t.Join();
                }
            }

client vient de la lib SSH.net

Merci

Voici un exemple plus simple qui ne fonctionne pas
Avez-vous une idée ?

Code:

Console.WriteLine("> " + text2);

n'est jamais appelé
Cela bloque au niveau du Join

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
using (AnonymousPipeServerStream pipeout = new AnonymousPipeServerStream(PipeDirection.Out))
            {
                using (AnonymousPipeClientStream pipein = new AnonymousPipeClientStream(PipeDirection.In,
                    pipeout.GetClientHandleAsString()))
                {
 
                    byte[] res;
                    Thread t = new Thread(() =>
                    {
                        using (MemoryStream x = new MemoryStream())
                        {
 
                            pipein.CopyTo(x);
                            res = x.ToArray();
                            string text2 = Encoding.UTF8.GetString(res);
                            Console.WriteLine("> " + text2);
 
 
                        }
                    });
                    t.Start();
 
                    string text = "hello !";
                    using (MemoryStream x = new MemoryStream(Encoding.UTF8.GetBytes(text)))
                    {
                        x.CopyTo(pipeout);
                    }
 
 
                    t.Join();
                }               
            }

29/06/2023, 09h07
Pol63

peut tu détailler un peu ce que tu veux faire transiter ? juste des strings ? des instances de classes contenant des données typées ?
c'est un truc sans fin (qui peut écrire plein de choses n'importe quand et chaque chose doit être traitée au fur et à mesure par une autre portion de code ?) ou juste une fois ?
ce sont 2 classes qui sont des threads différents ? des threads qui while true ?
y a 50 moyens de faire ça simplement, on va bien t'en trouver un ^^
29/06/2023, 09h16
François DORIN

Le problème vient de l'usage de CopyTo. CopyTo copie des informations tant que le stream est ouvert. Ici, rajouter un pipeout.Close() fermera le flux après y avoir écrit, permettant au reste du programme de tourner correctement.
29/06/2023, 13h13
bn0550

C'est effectivement ce que j'avais vu.
Merci