Multiprocessing Capture Signaux

Version imprimable

Bonjour,

Je m'amuse toujours avec le multiprocessing, et je tente maintenant de le tuer convenablement (même les process ont le droit à une belle mort).
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 from multiprocessing import Process,Pool,Queue import time def f(Multi_Queue): while not Multi_Queue.empty(): name=Multi_Queue.get() print 'hello', name time.sleep(4) print 'bye', name #if catch ctrl+c def signal_handler(signal,frame): ''' if it catch any ctrl+c it try to finish correctly ''' print '''please wait during the programme end''' p.terminate() exit() if __name__ == '__main__': signal.signal(signal.SIGINT, signal_handler) Test_Queue=Queue() Test_Queue.put('jeanne') p = Process(target=f, args=(Test_Queue,)) p.start() p.join()
Je lance donc un process et si vient un ctrl+c je veux ecrire une chaine de caractère avant.
Cependant avec ce code, le main comprend bien la chose, mais le process tente de faire pareil (et de s'auto-tuer) ce qui fait planter le programme.

Aussi quelqu'un connait il un moyen de terminer ca joliement sans un vilain message d'erreur à la fin ?

EDIT : toujours python 2.7 sous Debian Lenny

12/08/2011, 16h01
kango
bonjour,

ce programme ne donne pas de message d'erreur chez moi (Ubuntu 10.10, python 2.6.6):
Code:

1 2 3 hello jeanne ^Cplease wait during the programme end please wait during the programme end
Maintenant, je ne sais pas si c'est le résultat que tu attends :p

Et bien il entre deux fois dans la boucle de fin c'est pas cool :roll:

parce que si ensuite tu remplaces le terminate par un join donc :
Code:

1 2 3 4 5 6 7 8 #if catch ctrl+c def signal_handler(signal,frame): ''' if it catch any ctrl+c it try to finish correctly ''' print '''please wait during the programme end''' p.join() exit()
le fils tente de se joindre et il est pas content ....

(c'était une erreur de ma part de pas avoir mis le join directement j'avoue :?)

Bon comme je m'aime beaucoup je vais m'auto aider /o/

en vérifiant le PID du process on peut savoir s'il s'agit du main ou pas

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
from multiprocessing import Process,Pool,Queue
import time
import os
 
def f(Multi_Queue):
    while not Multi_Queue.empty():
        name=Multi_Queue.get()
        print 'hello', name
        time.sleep(4)    
    print 'bye', name
 
 
#if catch ctrl+c
def signal_handler(signal,frame):
    '''
    if it catch any ctrl+c it try to finish correctly
    '''
    if os.getpid()==PID:
      print '''please wait during the programme end'''
      p.terminate()
      exit()
 
 
if __name__ == '__main__':
 
      Main_PID=os.getpid()
      signal.signal(signal.SIGINT, signal_handler)
      Test_Queue=Queue()
      Test_Queue.put('jeanne')
      p = Process(target=f, args=(Test_Queue,))
      p.start()
      p.join()

ca marche pour le process et ca fait presque ce que je veux. (il saute le sleep mais ca c'est une autre histoire :cry:)

16/08/2011, 21h14
dividee

Bonjour,

par curiosité j'ai testé le code du premier post sous Windows, je m'attendais à un comportement légèrement différent et effectivement:

Les deux process reçoivent le signal (comme sous linux visiblement), mais seul le parent exécute le signal handler (le fils reçoit une exception KeyboardInterrupt).

J'image que la création de process est implémenté par un fork sous linux et que le processus fils hérite donc du signal handler. Une solution serait alors de déplacer l'installation du handler après la création du processus fils, ou d'installer un autre handler dans le processus fils lui-même. Mais la solution actuelle (tester le PID dans le handler) convient aussi bien sûr.
17/08/2011, 11h50
Alliaël

Bonjour,

Lancer la capture de signal après le création des process j'y avais pensé mais c'était pas terrible tout de même. (surtout que je créer des process en boucle)

Par contre un autre handler c'est génial je n'y avais pas pensé /o/

merci bien.