Discussion :

[Zakche]

Bonjour,

J'aimerai avoir de l'aide sur le code suivant.
Celui-ci fonctionne bien mais une seule fois... c'est embêtant pour un Thread.
J'ai identifié que le soucis vient du return du Thread readData.
Si je remplace l'expression return data par print(data), le serveur affichera la donnée reçue à chaque fois.
Par contre, si je laisse return ça fonctionne qu'une fois et je n'ai pas de message d'erreur ou autre...

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
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
 
import socket
from multiprocessing.pool import ThreadPool
 
def readData(conn):
    while True:
        try:
            data = conn.recv(1024).decode("utf8")
            return data
        except Exception as e:
            print(F"Erreur : {e}")
 
#------------------
host, port = ('192.168.1.101',2000)
 
socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
socket.bind((host,port))
socket.listen(5)
print('Serveur lancé...')
 
while True:
    try:
        conn, address = socket.accept()
        print('Client connecté ', address)
 
        pool = ThreadPool(processes=1)
        async_result = pool.apply_async(readData, (conn,))
 
        return_val = async_result.get()  
        print(return_val)
 
    except Exception as e:
        print(F"Erreur : {e}")

J'ai passé un temps fou à essayer de comprendre mais là je suis sec...
Merci par avance de votre aide.

[wiztricks]

Salut,

mutliprocessing, c'est pour avoir des activités asynchrones construites avec des process et non avec des Threads.

Si l'activité est matérialisée par une fonction i.e. on passe par "def toto" pour définir la séquence d'instructions qui seront exécutées par l'activité portée par un processus ou thread.

Ce n'est plus une fonction à proprement parler: elle est appelée indirectement par la machine à créer thread/process qui elle va appeler cette "fonction" et lorsqu'elle se termine, le (thread ou process) qui la porte se termine aussi.

Normal dans ces conditions que return termine l'activité (et processus/thread).

Par contre, sans "return", async_result.get() attend indéfiniment que l'activité se termine pour récupérer les données retournées via "return".

- W

[Zakche]

wiztricks merci pour cette réponse rapide.
Je voulais utiliser cette méthode car je ne voulais pas créer une classe readData qui aurait une variable global.
Je ne trouve pas ça top.

Je pense qu'il doit y avoir une méthode approprié pour les sockets mais tous les exemples que je trouve, finissent par print(message)...

Y'a t-il quelque chose que je rate?

Merci d'avance

[wiztricks]

Salut,

Y'a t-il quelque chose que je rate?

Ce que vous ratez est qu'en découper votre code en activités n'apporte rien si elles ne coopèrent pas i.e une activité produit des informations qui pourront être consommées par d'autres.

C'est sûr qu'on n'a pas ce soucis avez les fonctions "simples" puisqu'on part d'une sorte de hiérarchie intrinsèque où on a un appelant qui appelle une fonction pour réaliser une opération et qui attend le retour du résultat pour continuer.

Le "return" dans votre code fait juste çà de façon compliquée:

Code :

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

1
2
         async_result = pool.apply_async(readData, (conn,)) 
        return_val = async_result.get()

vous lancez la fonction readData via la création d'un processus puis vous attendez qu'elle se termine pour récupérer les données.

Autant écrire directement:

Code :

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

    result = readData(conn)

Et si vous voulez avoir un processus qui lise les données en permanence, pas la peine d'exécuter pool.apply_async(readData, (conn,)) dans une boucle! Vous créez une tache qui se terminera lorsque la socket est fermée et qui pousse les messages qu'elle récupère dans une Queue qui sera vidée par une autre activité.

- W

[Zakche]

Merci.

Je vais du coup me documenter sur l'objet Queue.