Discussion :

[snyfir]

Bonjour,

j'ai un script python qui contient un thread avec une condition wait infini.
Je souhaiterais par une ligne de commande linux réveiller ce thread.

Par exemple:

Lance pour la première fois l’application

Code :

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

./unProgrammePython

Envoi l'information au programme

Code :

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

./unAutreProgrammePython --WakeMe

Merci pour vos réponses.

[YCL-1]

Bonjour,

La méthode de communication inter-processus (IPC) la plus simple est sans doute via socket, en local.

Le programme principal attend sur une attente d'un message (sans timeout ou non bloquant qu'on scrute en permanence), serveur socket.

Et le second programme envoie un Go au principal en se connectant en tant que client au socket du programme principal.

server_socket_test.py

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
# Echo server program
import socket
 
HOST = "127.0.0.1"
PORT = 50007              # Arbitrary non-privileged port
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
conn, addr = s.accept()
print('Connected by', addr)
while True:
    data = conn.recv(1024)
    if not data: break
    conn.sendall(data)
conn.close()

client_socket_test.py

Code :

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

1
2
3
4
5
6
7
8
9
10
11
# Echo client program
import socket
 
HOST = "127.0.0.1"
PORT = 50007              # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.sendall(b'Hello, world')
data = s.recv(1024)
s.close()
print('Received', repr(data))

Source: https://docs.python.org/3.4/library/socket.html

Il suffit de lancer server_socket_test.py avant client_socket_test.py

[snyfir]

Bonjour,

La méthode de communication inter-processus (IPC) la plus simple est sans doute via socket, en local.

Le programme principal attend sur une attente d'un message (sans timeout ou non bloquant qu'on scrute en permanence), serveur socket.

Et le second programme envoie un Go au principal en se connectant en tant que client au socket du programme principal.

server_socket_test.py

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
# Echo server program
import socket
 
HOST = "127.0.0.1"
PORT = 50007              # Arbitrary non-privileged port
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.bind((HOST, PORT))
s.listen(1)
conn, addr = s.accept()
print('Connected by', addr)
while True:
    data = conn.recv(1024)
    if not data: break
    conn.sendall(data)
conn.close()

client_socket_test.py

Code :

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

1
2
3
4
5
6
7
8
9
10
11
# Echo client program
import socket
 
HOST = "127.0.0.1"
PORT = 50007              # The same port as used by the server
s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
s.connect((HOST, PORT))
s.sendall(b'Hello, world')
data = s.recv(1024)
s.close()
print('Received', repr(data))

Source: https://docs.python.org/3.4/library/socket.html

Il suffit de lancer server_socket_test.py avant client_socket_test.py

Le problème de cette méthode est que mon serveur va utiliser du cpu à scruter en permanence si une donnée a été envoyé. Peut on le faire en gardant le serveur en sommeil?

[BufferBob]

Le problème de cette méthode est que mon serveur va utiliser du cpu à scruter en permanence si une donnée a été envoyé. Peut on le faire en gardant le serveur en sommeil?

ça dépend complètement de ta définition de "condition wait infinie", on peut essayer de deviner par élimination mais ça ira probablement plus vite si tu mets un bout de code explicite à disposition de ceux qui vont tenter de t'aider

[snyfir]

ça dépend complètement de ta définition de "condition wait infinie", on peut essayer de deviner par élimination mais ça ira probablement plus vite si tu mets un bout de code explicite à disposition de ceux qui vont tenter de t'aider

Ce que je veux dire par wait infinie est que le thread ce bloque et ne se réveille uniquement que si on le lui demande.
Exemple avec un sémaphore:

Code :

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

1
2
3
4
5
 
semaphore = threading.BoundedSemaphore()
semaphore.acquire() # block the thread until is delockink
... do the job
semaphore.release()

[BufferBob]

Ce que je veux dire par wait infinie est que le thread ce bloque et ne se réveille uniquement que si on le lui demande.

ah ok, avec un while 1: sleep(50000) alors, ou via un signal SIGSTOP c'est ça ? ou un subprocess.Popen.wait() qui tourne dans le vide peut-être ?

Exemple avec un sémaphore

ahhh ok, au temps pour moi donc ta question finalement, c'est de savoir comment on réveille un sémaphore ?

par contre et pour la petite info, un thread est un processus mais un processus n'est pas un thread, si tu lances 2 programmes distincts comme dans ton premier message avec ./UnProgrammePython, ./UnAutreProgrammePython --WakeMe t'es plus dans le contexte d'utilisation des threads, c'est 2 processus distincts et les sémaphores non plus ne fonctionnent pas

c'est juste un malentendu avec ton premier post ou y'a bien une confusion au niveau des techno à utiliser de ton coté ?

[snyfir]

ah ok, avec un while 1: sleep(50000) alors, ou via un signal SIGSTOP c'est ça ? ou un subprocess.Popen.wait() qui tourne dans le vide peut-être ?


ahhh ok, au temps pour moi donc ta question finalement, c'est de savoir comment on réveille un sémaphore ?

par contre et pour la petite info, un thread est un processus mais un processus n'est pas un thread, si tu lances 2 programmes distincts comme dans ton premier message avec ./UnProgrammePython, ./UnAutreProgrammePython --WakeMe t'es plus dans le contexte d'utilisation des threads, c'est 2 processus distincts et les sémaphores non plus ne fonctionnent pas

c'est juste un malentendu avec ton premier post ou y'a bien une confusion au niveau des techno à utiliser de ton coté ?

Enfaite je sais utiliser les sémaphores dans un même processus.
Ma question est plus comment faire pour réveiller un thread d'un processus à partir d'un autre processus. En sachant que je veux garder le premier processus au repos le plus possible (c'est à dire ne pas devoir le réveiller en permanence pour surveiller si un autre processus veux lui envoyer une commande).
En espérant être plus claire.

[BufferBob]

Enfaite je sais utiliser les sémaphores dans un même processus.
Ma question est plus comment faire pour réveiller un thread d'un processus à partir d'un autre processus. En sachant que je veux garder le premier processus au repos le plus possible (c'est à dire ne pas devoir le réveiller en permanence pour surveiller si un autre processus veux lui envoyer une commande).
En espérant être plus claire.

donc si je comprends bien il y a au moins 3 processus en jeu, UnProgrammePython, qui va lancer au moins 1 thread en l'air tandis que le thread principal va servir de scheduler et notifiera son thread fils pour lui dire de relacher le sémaphore, et UnAutreProgrammePython qui lui donne l'ordre au scheduler de UnProgrammePython de réveiller son fiston, ce qui finalement revient à avoir un thread fils endormi, tandis que le thread principal/père/sched. reste à l'écoute d'une donnée arrivant d'un autre programme

je ne t'apprends donc rien, les sémaphores servent à acquérir ou relâcher des ressources, pas à attendre ou à endormir un processus, si tu veux vraiment endormir ton processus le meilleur moyen est de le stoper via un signal SIGSTP et à ce moment là tu peux envisager de le réveiller en lui envoyant un signal SIGCONT (en admettant que tu aies sont pid )

c'est pas magique, un sémaphore est une structure stockée en mémoire, entre plusieurs threads (processus légers, qui partagent le même espace d'adressage) le sémaphore est disponible, mais entre deux processus standards qui ne partagent pas le même espace d'adressage il n'y a aucun moyen pour le 1er processus de relâcher un sémaphore dans le 2nd processus