Réveiller un thread python par une ligne de commande linux

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:

---

./unProgrammePython

---

Envoi l'information au programme

Code:

---

./unAutreProgrammePython --WakeMe

---

Merci pour vos réponses.

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:

---

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:

---

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

Citation:

---

Envoyé par 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:

---

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:

---

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?

Citation:

---

Envoyé par snyfir

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

Citation:

---

Envoyé par BufferBob

ç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:

---

1 2 3 4 5

semaphore = threading.BoundedSemaphore() semaphore.acquire() # block the thread until is delockink ... do the job semaphore.release()

---

Citation:

---

Envoyé par snyfir

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 ?

Citation:

---

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é ?

Citation:

---

Envoyé par BufferBob

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.

Citation:

---

Envoyé par snyfir

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 :mrgreen:)

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