Discussion :

[____22]

Bonjour
est-ce que time.sleep(-1) lance un process qui ne se termine jamais? j'ai besoin d'un thread qui attend un temps variable, ou n'attend pas et ne fais rien, je voulais mettre alors des temps negatifs pour ça mais ça n'a pas l'air interressant

je voudrais pouvoir changer ce temps et en le mettant negatif par exemple le thread se met en pause

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
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
import threading
import time
 
class timeout(threading.Thread):
    def __init__(self, rate = 60):
        threading.Thread.__init__(self)
        self.rate = rate
        self.stopped=False
    def run(self):
        while self.rate>0:
            print self.rate, time.time()
            time.sleep(self.rate)
        self.stopped=True
        print "timeout end"
    def setrate(self, rate):
        self.rate = rate 
        if self.stopped:
            print "timeout restart"
            self.start()  
 
class changer(threading.Thread):
    def __init__(self):
        threading.Thread.__init__(self)
    def run(self):
        time.sleep(10)
        global tout
        tout.setrate(2)
        time.sleep(10)
        tout.setrate(-1)
        time.sleep(10)
        tout.setrate(5)
        print "changer" 
 
 
global tout       
tout=timeout(5)
tout.start()
changer().start()

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
16
17
18
19
5 1290776845.79
5 1290776850.8
5 1290776855.8
2 1290776860.8
2 1290776862.8
2 1290776864.81
timeout end
timeout restart
Exception in thread Thread-2:
Traceback (most recent call last):
  File "/usr/lib/python2.6/threading.py", line 532, in __bootstrap_inner
    self.run()
  File "test.py", line 31, in run
    tout.setrate(5)
  File "test.py", line 19, in setrate
    self.start()
  File "/usr/lib/python2.6/threading.py", line 467, in start
    raise RuntimeError("thread already started")
RuntimeError: thread already started

[nyko77]

Bonjour,
Franchement c'est pas très clair.
Pour le time.sleep(-1), à moins que tu veuilles faire une application qui remonte le temps, ça me semble un peu bizarre.

j'ai besoin d'un thread qui attend un temps variable, ou n'attend pas et ne fais rien

On croirait une devise shadock.
A quoi sert quelque chose qui n'attend pas et qui ne fait rien? autant ne rien faire.

Je pense qu'il va falloir donner plus d'explication si tu veux que quelqu'un d'aide.

Sinon, ton message d'erreur vient du faite que tu relances le thread déjà lancé, à la fin de la méthode setrate. Si tu veux le relancer il faut d'abord le stopper, c'est à dire que l'exécution du code se finisse.
Ensuite les variables globales sont à proscrire en POO. Tu peux passer l'instance de timeout en argument de changer, pour y accéder.
Il est également recommandé de mettre des majuscule aux noms de classes.

[____22]

bon il me faut un thread qui fait une tache tous les rate secondes
et j'ai une autre classe capable de changer le rate par setrate, je voudrais qu'on puisse mettre un rate de 10s, 15s ou un rate de -1 de façon à ce que la tache s'arrete momentanément jusqu'a ce que on lui remette en rate >0

Sinon, ton message d'erreur vient du faite que tu relances le thread déjà lancé, à la fin de la méthode setrate. Si tu veux le relancer il faut d'abord le stopper, c'est à dire que l'exécution du code se finisse.

"timemout end" montre que run s'est terminé, je vois pas comment le relancer sans avoir cette erreur

Ensuite les variables globales sont à proscrire en POO. Tu peux passer l'instance de timeout en argument de changer, pour y accéder.
.

ok

[VinsS]

Salut,

Tout d'abord, changer la valeur de time.sleep() pendant qu'il s'exécute, me parait hautement improbable.

Je vais tester ça, ça m'intrigue.

Pour ton problème de tâche, je pense que tu te faciliterais la vie en créant une nouvelle instance du thread à chaque changement de rate.

Avec threading.enumerate() tu pourras contrôler les process en vie et tu verras qu'il n'y a aucun risque d'emballement démographique, les threads ayant accomplit leur tâche disparaissent directement de la liste.

[VinsS]

J'ai modifié ton code pour tester la chose :

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
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
 
import threading
import time
 
class timeout(threading.Thread):
    def __init__(self, rate = 60):
        threading.Thread.__init__(self)
        self.rate = rate
 
    def run(self):
        print self.rate, time.time()
        time.sleep(self.rate)
        print "timeout end", time.time()
 
    def setrate(self, rate):
        self.rate = rate   
 
class changer(threading.Thread):
    def __init__(self, tout):
        threading.Thread.__init__(self)
        self.tout = tout
 
    def run(self):
        time.sleep(2)
        self.tout.setrate(2)
 
tout = timeout(10)
tout.start()
ch = changer(tout)
ch.start()

Je confirme, c'est absolument sans effet.

[____22]

ok c'est un peu ça que je voulais faire: mais c'est un exemple extrait du reste il faut que l'inclue maintenant merci

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
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
import threading
import time
 
class Timeout(threading.Thread):
    def __init__(self, rate = 60):
        threading.Thread.__init__(self)
        self.rate = rate
        self.stopped=False
    def run(self):
        while self.rate>0:
            print " ",self.rate, time.time(), threading.enumerate()
            time.sleep(self.rate)
        self.stopped=True
        print "timeout ", self.__str__(), "end"
    def setrate(self, rate):
        self.rate = rate
    def isstopped(self):
        return self.stopped
 
 
class Changerate(threading.Thread):
    def __init__(self, timeoutthread):
        threading.Thread.__init__(self)
        self.timeouthread=timeoutthread
    def run(self):
        time.sleep(10)
        self.timeouthread.setrate(1)
        print "1", self.timeouthread.isAlive(),self.timeouthread.isstopped()
        if self.timeouthread.isstopped():
            self.timeouthread=Timeout(self.timeouthread.rate)
            self.timeouthread.start()
        time.sleep(10)
        self.timeouthread.setrate(0)
        print "2", self.timeouthread.isAlive(),self.timeouthread.isstopped()
        if self.timeouthread.isstopped():
            self.timeouthread=Timeout(self.timeouthread.rate)
            self.timeouthread.start()
        time.sleep(10)
        self.timeouthread.setrate(3)
        print "3", self.timeouthread.isAlive(),self.timeouthread.isstopped()
        if self.timeouthread.isstopped():
            self.timeouthread=Timeout(self.timeouthread.rate)
            self.timeouthread.start()
        time.sleep(10)
        self.timeouthread.setrate(1)
        print "4", self.timeouthread.isAlive(),self.timeouthread.isstopped()
        if self.timeouthread.isstopped():
            self.timeouthread=Timeout(self.timeouthread.rate)
            self.timeouthread.start()
 
 
 
tout=Timeout(2)
tout.start()
 
Changerate(tout).start()
 
print "0", threading.enumerate()