Stopper un thread par un signal

Version imprimable

Bonjour,
Après de bonnes heures de lectures et de tests, je bloque sur la methode pour stopper un code qui lui-même a lancé des threads.
Dans l'exemple ci-dessous, avec un timer pour donner une limitte d'execution, tout se passe bien, le code et ses threads sont correctements stoppés.
Sans le timer, je ne trouve pas le moyen de stopper tout ceci par un signal (ctrl+c ou kill -15).
Merci par avance pour votre aide.
Python 2.4 utilisé sur Debian.

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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
 
class agent1(threading.Thread):
	def __init__(self, nom = ''):
		threading.Thread.__init__(self)
		self.nom = nom
		self._stopevent = threading.Event( )
		print datetime.datetime.now(),"Start",self.nom
	def run(self):
		while not self._stopevent.isSet():
			self._stopevent.wait(10 - (int(time.time()) % 10))
			print datetime.datetime.now(),"Run",self.nom
			## doing my job
	def stop(self):
		print datetime.datetime.now(),"Stop",self.nom
		self._stopevent.set( )
 
 
class agent2(threading.Thread):
	def __init__(self, nom = ''):
		threading.Thread.__init__(self)
		self.nom = nom
		self._stopevent = threading.Event( )
		print datetime.datetime.now(),"Start",self.nom
	def run(self):
		while not self._stopevent.isSet():
			self._stopevent.wait(20 - (int(time.time()) % 20))
			print datetime.datetime.now(),"Run",self.nom
			## doing my job
	def stop(self):
		print datetime.datetime.now(),"Stop",self.nom
		self._stopevent.set( )
 
 
def exit(signum,frame):
	a.stop()
	b.stop()
	print datetime.datetime.now(),"Exiting (%d) ..."%(signum)
	sys.exit(signum)
 
 
if __name__=="__main__":
	print datetime.datetime.now(),"Start"
 
	a = agent1('agent1')
	b = agent2('agent2')
 
	signal.signal(signal.SIGTERM, exit)
	signal.signal(signal.SIGINT, exit)
 
	a.start()
	b.start()
 
	#time.sleep(60.0)
	#a.stop()
	#b.stop()

Voici les modifications apportées pour que le CTRL+C ainsi que le kill -15 fonctionnent :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
 
if __name__=="__main__":
	signal.signal(signal.SIGTERM, exit)
	signal.signal(signal.SIGINT, exit)
 
	print datetime.datetime.now(),"Start"
 
	a = agent1('agent1')
	b = agent2('agent2')
 
	a.start()
	b.start()
 
	while True:
		continue

04/04/2007, 12h42
kazh75

En ajoutant, le code ci-dessus, le thread principal prend 100% du cpu.
En retirant le code ci-dessus, je ne trouve pas moyen de stopper le programme autrement que par un kill -9.

Le code final et fonctionnel :

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
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
 
#!/usr/bin/python2.4
# -*- coding:Latin-1 -*-
 
## ----------------------------------------------------------------------
## Modules
## ----------------------------------------------------------------------
import sys
import signal
import os
import threading
import time
import datetime
 
 
## ----------------------------------------------------------------------
## Fonctions
## ----------------------------------------------------------------------
def bye(signum,frame):
	agent1.stop()
	agent2.stop()
	print datetime.datetime.now(),"Exit (%d)"%(signum)
	sys.exit(signum)
 
 
## ----------------------------------------------------------------------
## Classes
## ----------------------------------------------------------------------
class myThread(threading.Thread):
	def __init__(self,myTimer):
		self.timer = myTimer
		threading.Thread.__init__(self)
	def run(self):
		self.event = threading.Event()
		print datetime.datetime.now(),"Start",self.getName()
		while not self.event.isSet():
			self.event.wait(self.timer - (int(time.time()) % self.timer))
			print datetime.datetime.now(),"Run",self.getName()
	def stop(self):
		print datetime.datetime.now(),"Stop",self.getName()
		self.event.set()
 
 
## ----------------------------------------------------------------------
## Main
## ----------------------------------------------------------------------
signal.signal(signal.SIGTERM, bye)
signal.signal(signal.SIGINT, bye)
 
print datetime.datetime.now(),"Start"
 
agent1 = myThread(10)
agent1.setName('agent1')
agent1.start()
 
agent2 = myThread(5)
agent2.setName('agent2')
agent2.start()
 
 
while True:
	time.sleep(60.0)

04/04/2007, 14h53
parp1

Je tire mon chapeau bien bas l'ami! Tu a résolut ton probleme seul et sans la moindre aide... C'est pas moi qui aurait pu t'en donner