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