Discussion :

[guenaule]

bonjour,

je voudrais utiliser la fonctionnalité timer du module threading
mais je n'arrive pas a passer des arguments a la classe

un exemple est montre sur le site mais sans passage de parametre

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
class MyTimer:
    def __init__(self, tempo, target, args= [], kwargs={}):
        self._target = target
        self._args = args
        self._kwargs = kwargs
        self._tempo = tempo
 
 
    def _run(self):
        self._timer = threading.Timer(self._tempo, self._run)
        self._timer.start()
        self._target(*self._args, **self._kwargs)
 
    def start(self):
        self._timer = threading.Timer(self._tempo, self._run)
        self._timer.start()
 
    def stop(self):
        self._timer.cancel()
 
def gabarit():
     print unstr, time.clock()
 
 
Te=0.5
a = MyTimer(Te,gabarit,["MyTimer"])
 
 
a.start()
time.sleep(5.5)
print "Timer arrete"
a.stop()
time.sleep(2.0)

[dividee]

Je ne sais pas si j'ai bien compris ce que tu veux, mais il me semble qu'il manque simplement le paramètre unstr à la fonction gabarit pour que cet exemple soit fonctionnel:

Code python :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
def gabarit(unstr):
    print unstr, time.clock()

Et s'il te plaît, utilise la balise [code] ! Merci Guigui_ !

[tyrtamos]

Bonjour,

Je ne comprend pas bien ce que tu veux faire, mais tu devrais regarder directement le code source du module threading.py qui se trouve dans lib. Le code concernant Timer est d'une vingtaine de lignes, et il est très intéressant. On y apprend, par exemple, que threading.Timer est une fonction, et pas une classe. C'est cette fonction qui appelle la classe threading ._Timer. Tu pourras voir aussi comment les arguments passés à la fonction threading.Timer (au delà de tempo et target) finissent par être transmis à la fonction target. Et pour un besoin plus complexe, tu devrais pouvoir créer une classe dérivée de threading._Timer, ou t'inspirer du code pour faire ta propre classe.

Tyrtamos

[guenaule]

En fait,

je voudrais appeler une fonction tous les 50 ms, laquelle effectue
un traitement mathematique et stocke tous les pas de calcul dans
un csv.
j'ai vu que la classe timer du module threading possede deux arguments (args et kwargs), mais je n'ai pas pu passer mes parametres
a la fonction.

je vais essayer de comprendre la librairie en interne,
pour voir ce que je peux faire

[tyrtamos]

Voilà un petit code simplet qui montre la transmission des arguments.

Au lancement, le programme principal initialise le timer, le lance et attend qu'il ait terminé (join()).

Le timer attend 5 secondes et lance le calcul avec les 2 arguments fournis présentés sous forme de tuple.

Le timer se termine alors, ce qui permet au programme principal de poursuivre et d'afficher le résultat.

Code :

Sélectionner tout - Visualiser dans une fenêtre à part

1
2
3
4
5
6
7
8
9
10
11
12
13
14
 
import threading
 
result=0
 
def calcul(x,y):
    global result
    result=x*y
 
c=threading.Timer(5,calcul,(2,3))
c.start()
c.join()
 
print result

Les arguments passés ici sous forme d'un tuple peuvent être suivis par des arguments nommés, présentés alors sous forme d'un dictionnaire.

Tyrtamos

[guenaule]

merci tyrtamos,

tu m'as donné des idées,
du coup j'ai repris mon exemple ci_dessus, et j'ai ajouté
une phase d'init, on peut ainsi initialiser les parametres au premier
lancement

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
59
60
61
import csv
import threading
import time
 
 
class MyTimer:
    def __init__(self, tempo, target, args= [], kwargs={}):
        self._target = target
        self._args = args
        self._kwargs = kwargs
        self._tempo = tempo
        self.record_data  = []
        self.state  = "INIT"
 
 
    def _run(self):
        self._timer = threading.Timer(self._tempo, self._run)
        self._timer.start()
        self.state = self._target(self.state,*self._args, **self._kwargs)
 
    def start(self):
        self._timer = threading.Timer(self._tempo, self._run)
        self._timer.start()
 
    def stop(self):
        self._timer.cancel()
 
    def display(self):
        print self.record_data
 
 
 
def calcul(state,x,y):
 
    if state == "INIT":
        result = x+y+8
        state  = "RUN"
    else:
        result = x+y+7
    print result
    return state
 
 
 
 
 
 
 
## main
 
Te=0.05
input = 2
a = MyTimer(Te,calcul,(2,3))
 
 
a.start()
time.sleep(2)
print "Timer arrete"
print a.display():D
a.stop()
time.sleep(2.0)