Discussion :

[Gecko]

Bonjour tout le monde!

J'ai un petit problème avec ma gestion des Thread dans une classe que je dev. En gros j'ai la fonction onLoad() qui me sert à charger checkIn(). Checkin fait appel à Threading.Timer() pour être répétée toutes les 0.5 secondes. Le problème que j'ai c'est que le traitement lui peut durer plus longtemps en fonction du nombre de données à traiter.

Du coup j'aimerai que Threading.Timer() fasse la relance qu'une fois le traitement fini, histoire de pas surcharger pour rien.

Code python :

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

1
2
3
4
5
6
7
8
9
10
11
12
13
 
import threading
 
class autocheck(Plugin):
 
  def onLoad(self):
    self.cid = 21
    self.cll = {}
    self.checkIn()
 
  def checkIn(self):
    threading.Timer(0.5, self.checkIn).start()
    # traitement

J'ai tenté de "tricher" en plaçant mon thred à la fin de ma fonction mais ça n'a pas fonctionné, je m'y attendait donc je ne suis pas déçu

Faut savoir que c'est la première fois que j'utilise les thread, je dev "sérieusement" sous Python depuis 15 jours du coup j'ai encore du mal avec certains aspects du langage.

Merci d'avance pour votre aide

[wiztricks]

Salut,

checkin sera exécuté par le thread associé à Timer. Si vous voulez attendre que çà se termine, vous pouvez faire un .join.
Exemple:

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
from threading import Timer
import time
 
def checkin():
    print ('checkin')
    time.sleep(1)
 
def submit_checkin(count=5):
    for x in range(count):
        t = Timer(0.5, checkin)
        t.start() 
        t.join()
        print (x)
 
submit_checkin()

Ceci dit créer et détruire un thread pour faire çà, c'est "luxe"!
Il serait quand même plus raisonnable de créer un thread qui lance checkin après avoir attendu 0.5 secondes: çà ne crée qu'un seul thread.

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
from threading import Thread
import time
 
def checkin():
    print ('checkin')
    time.sleep(1)
 
def submit_checkin(count=5):
    for x in range(count):
        time.sleep(0.5)
        checkin()
        print (x)
 
thread = Thread(target=submit_checkin)
thread.start()
thread.join()

- W