[Threading] [Pyserial]Problème de fuite mémoire

Version imprimable

Bonjour,

Je me permet de poster car je dois ré-écrire un programme en python et je débute avec ce langage.

Mon application, dont le code allégé figure ci-dessous, se charge d'échanger des informations avec un port COM USB. Cette partie fonctionne bien.
J'ai voulu rajouter une détection de connexion/déconnexion du port COM. Il ne me semble pas que la librairie PYSERIAL permette ce genre de chose, mais je me trompe peut-être. Du coup je fais du polling...

Ma première question est : Peut-on faire la même chose de manière plus élégante ?

Pour ce polling, j'ai utilisé maladroitement les Threads,, enfin plus précisément les Timers. Ca fonctionne bien, mais à chaque appel de ma méthode "connexionPIC", la quantité de mémoire occupée par le script python augmente, et après plusieurs heures Windows 7 m'affiche une erreur.
Je pense que le problème vient du fait que ma fonction s'appelle, d'une certaine façon, elle-même. Un delete bien placé pourrait peut-être solutionner le problème, mais je ne sais pas comment l'utiliser correctement (mais essais sont restés infructueux).

Ma seconde et dernière question est donc : Comment empêcher cette fuite de mémoire qui, sur le long terme, est pénalisante ? L'utilisation de thread peut-elle être évitée ? (sachant qu'en parallèle, d'autres event de l'utilisateur peuvent survenir)
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 class APPLI(object): def __init__(self): #Blablabla #... #... self.win.mainloop() #Connexion au port com def connexionPIC(self): self.threading = threading self.threading.timer = self.threading.Timer(0.5,self.connexionPIC) self.threading.timer.start() VID = 0x04D8 PID = 0x000A device_list = list_ports.comports() port = None for device in device_list: if(device.vid == VID and device.pid == PID): port = device.device break if (port!=None): print("Port COM trouvé") test = APPLI() test.threading.timer.cancel() test.threading.Thread.join
Merci d'avance pour les pistes que vous saurez me donner !

02/03/2017, 19h01
wiztricks
Citation:

Envoyé par adrien49

Ma première question est : Peut-on faire la même chose de manière plus élégante ?

Pas avec PySerial en tous cas.

Citation:

Envoyé par adrien49

Je pense que le problème vient du fait que ma fonction s'appelle, d'une certaine façon, elle-même. Un delete bien placé pourrait peut-être solutionner le problème, mais je ne sais pas comment l'utiliser correctement (mais essais sont restés infructueux).

C'est une théorie que vous devriez pouvoir tester avec un exemple du genre:
Code:

1 2 3 4 5 6 7 >>> from threading import Timer >>> def f(): ... p = Timer(0.5, f) ... p.start() ... print('f') ... >>> f()
Soi vous reproduisez le problème et c'est un bug à remonter aux développeurs Python, soit vous ne le reproduisez pas et il faut chercher de quoi se remplit la mémoire.

- W

Bonjour,

Le fait que le timer s'appelle lui-même ne me semble pas être une bonne idée.

En fait, le problème est qu'on veut une surveillance permanente, par exemple en appelant une fonction de test toutes les 0.5 seconde, alors que threading.Timer n'appelle la fonction qu'une seule fois après la durée donnée.

En ce qui me concerne, j'utilise dans ce cas un thread qui contient l'exécution d'un Timer dans une boucle while. Ainsi, on attend la fin du Timer précédent avant de lancer le suivant.

Voilà un exemple de code:

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
import time
import threading
 
class Intervallometre(threading.Thread):
    """permet d'appeler une foncton toutes les x secondes
    """
    def __init__(self, duree, fonction, args=[], kwargs={}):
        threading.Thread.__init__(self)
 
        # stocke les arguments donnés à l'appel
        self.duree = duree
        self.fonction = fonction
        self.args = args
        self.kwargs = kwargs
 
        # pour permettre l'arrêt a la demande
        self.encore = True  
 
    def run(self):
        """ partie exécutée en tâche de fond
        """
        while self.encore:
            self.timer = threading.Timer(self.duree, self.fonction, self.args, self.kwargs)
            self.timer.setDaemon(True)
            self.timer.start()
            self.timer.join() # on attend que le timer ait appelé la fonction
 
    def stop(self):
        """ méthode à appeler pour stopper l'intervallomètre
        """
        self.encore = False  # pour empêcher un nouveau lancement de Timer et terminer le thread
        if self.timer.isAlive():
            self.timer.cancel()  # pour terminer une éventuelle attente en cours de Timer
 
def test(ch):
    print(ch)
 
t = time.time()
intervallometre = Intervallometre(0.5, test, ["toto"])
intervallometre.start()
 
# on attend 10 secondes pendant lesquelles la fonction test s'exécute périodiquement
while time.time() - t <= 10:
    pass
 
# on stoppe l'intervallometre
intervallometre.stop()
 
print("===> FIN")

03/03/2017, 09h34
wiztricks

Salut,

Citation:

Envoyé par adrien49

L'utilisation de thread peut-elle être évitée ? (sachant qu'en parallèle, d'autres event de l'utilisateur peuvent survenir)

Comme vous utilisez un GUI, vous disposez de la possibilité d'ordonnancer l'appel d'une fonction sans passer par les threads (mais elle dépend du GUI que vous utilisez). Mais que cette opération soit lancée par un thread ou par le GUI ne devrait pas changer grand chose côté fuite mémoire (dont la cause reste à déterminer, et pour cela arriver à le reproduire "hors application").

- W
03/03/2017, 10h44
adrien49

Citation:

Envoyé par wiztricks

Pas avec PySerial en tous cas.

Merci pour votre aide. Peut être avez-vous une autre librairie à me suggérer?

Citation:

Soi vous reproduisez le problème et c'est un bug à remonter aux développeurs Python, soit vous ne le reproduisez pas et il faut chercher de quoi se remplit la mémoire.

Après quelques heures à tourner, l'occupation mémoire est toujours à peu près la même. Du coup ce n'est pas ça le problème, mais c'est plutôt lié à mon application.

Citation:

Envoyé par wiztricks

Salut,
Comme vous utilisez un GUI, vous disposez de la possibilité d'ordonnancer l'appel d'une fonction sans passer par les threads (mais elle dépend du GUI que vous utilisez). Mais que cette opération soit lancée par un thread ou par le GUI ne devrait pas changer grand chose côté fuite mémoire (dont la cause reste à déterminer, et pour cela arriver à le reproduire "hors application").

L'essai précédent semble m'orienter dans ce sens. Je vais refaire une batterie d'essai pour mieux localiser le problème. J'utilise tkinter

Merci à tyrtamos aussi pour sa solution, que je vais essayer aussi car elle me parait plus "propre".

Citation:

Envoyé par adrien49

L'essai précédent semble m'orienter dans ce sens. Je vais refaire une batterie d'essai pour mieux localiser le problème. J'utilise tkinter

Avec tkinter, pour des opérations courtes (et récupérer la liste des interfaces connectées sur un bus devrait être assez rapide), on peut utiliser .after.
Ce que raconte Tyrtamos est que la durée de traitement pouvant être plus longue que l'attente, il est préférable de d'écrire:
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 def connexionPIC(self): VID = 0x04D8 PID = 0x000A device_list = list_ports.comports() port = None for device in device_list: if(device.vid == VID and device.pid == PID): port = device.device break if (port!=None): print("Port COM trouvé") self.threading = threading self.threading.timer = self.threading.Timer(0.5,self.connexionPIC) self.threading.timer.start()
i.e. faire le traitement avant de lancer le Timer suivant histoire qu'on ne se retrouve pas avec plein de traitements simultanés.

- W