Lancer un thread et passage de paramètre

Lancer un thread et passage de paramètre - Python - Programmation

Marsh Posté le 28-05-2004 à 16:48:06    


Salut à tous,
 
je suis en train de me lancer dans les thread, et j'ai récupérer plusieurs infos entre la doc et les exemples sur internet.
 
j'en suis arrivé à faire ceci :
 
 

Code :
  1. import threading
  2. import deleteFile
  3. import time
  8. class Task( threading.Thread ):
  9.     def __init__( self, action, loopdelay, initdelay ):
  10.         self._action = action
  11.         self._loopdelay = loopdelay
  12.         self._initdelay = initdelay
  13.         self._running = 1
  14.         threading.Thread.__init__( self )
  16.     def __repr__( self ):
  17.         return '%s %s %s' % (
  18.             self._action, self._loopdelay, self._initdelay )
  20.     def run( self ):
  21.         if self._initdelay:
  22.             time.sleep( self._initdelay )
  23.         self._runtime = time.time()
  24.         while self._running:
  25.             start = time.time()
  26.             self._action()
  27.             self._runtime += self._loopdelay
  28.             time.sleep( self._runtime - start )
  30.     def stop( self ):
  31.         self._running = 0
  35.    
  36. class Scheduler:
  37.     def __init__( self ):
  38.         self._tasks = []
  39.        
  40.     def __repr__( self ):
  41.         rep = ''
  42.         for task in self._tasks:
  43.             rep += '%s\n' % `task`
  44.         return rep
  45.        
  46.     def AddTask( self, action, loopdelay, initdelay = 0 ):
  47.         task = Task( action, loopdelay, initdelay )
  48.         self._tasks.append( task )
  49.    
  50.     def StartAllTasks( self ):
  51.         for task in self._tasks:
  52.             task.start()
  53.    
  54.     def StopAllTasks( self ):
  55.         for task in self._tasks:
  56.             print 'Stopping task', task
  57.             task.stop()
  58.             task.join()
  59.             print 'Stopped'
  63. if __name__ == '__main__':
  65.     def t1() :
  66.         print "t1"
  68.     s = Scheduler()
  69.     s.AddTask(t1, 1, 0)
  70.     s.StartAllTasks()
  71.     raw_input()
  72.     s.StopAllTasks()


 
ce que je n'arrive pas à faire, c'est mettre un paramètre à la fonction t1(arg). Puis de le passer dans s.AddTask(t1(arg), ...) ou s.AddTask(t1,..., arg).
 
 
Si vous avez des idées.
 
 
Merci

Reply

Marsh Posté le 28-05-2004 à 16:48:06   

Reply

Marsh Posté le 28-05-2004 à 16:52:34    

wrap tout dans une autre fonction ou une lamnda
 
s.AddTash(lambda : t1(x), ...)
 
 
pour attêter tes thread utilises des threading.Event et pas des sleep

Reply

Marsh Posté le 28-05-2004 à 17:14:13    

Merci beaucoup, ça marche bien, mais j'ai un autre problème.
 
Je veux lancer t1(x) avec des arguments différents, donc je pensait faire :  
 

Code :
  1. x = "toto1"
  2. s.AddTash(lambda : t1(x), ...)
  4. x = "toto2"
  5. s.AddTash(lambda : t1(x), ...)


 
Mais ça me prend en compte toujours "toto2".
pourtant je pensait que chaque thread garderait son paramètre ?

Reply

Marsh Posté le 28-05-2004 à 17:15:20    

ben tu leur passe x, donc la référence, si tu modifies x ...

Reply

Marsh Posté le 28-05-2004 à 17:18:45    

Oui, justement.
 
en fait je lis un fichier avec des paramètres.
Mais je ne sais pas combien de paramètres je vais avoir donc, je lis une ligne, je met le paramètre dans x et je fais mon AddTask(t1(x), ...).
 
Je vais chercher un peu ...
 
Merci

Reply

Marsh Posté le 28-05-2004 à 18:37:52    


Voilà, j'essaie de passer par un dictionnaire.
Donc je crée un dictionnaire : dict = {}
Puis dans une boucle, je lis mon fichier ligne par ligne et j'ajoute les arguments dans mon dictionnaire :  
 

Code :
  1. dict[i] = arg
  2. i = i + 1


 
à la fin de la boucle, quand j'affiche  dict, tout est OK, j'ai bien tous mes arguments.
Ensuite, je fais mes :
 

Code :
  1. AddTask(lambda : a[i], int(arg3), int(arg4))


dans une autre boucle, mais j'ai l'erreur suivante :  
 
AddTask(lambda : a[i], int(arg3), int(arg4))
KeyError: 2
 
 
 
Merci de votre aide.

Reply

Marsh Posté le 28-05-2004 à 18:38:55    

oupss :  
 
la dernière ligne est :
 
AddTask(lambda : dict[i], int(arg3), int(arg4))  
KeyError: 2  
 
 
désolé, faute de frappe

Reply

Marsh Posté le 28-05-2004 à 18:51:29    

écoute : consolide tes bases (parce que la tu bites rien aux références) et après crée un objet fonction (un objet qui porte ses arguments et qui fournit __call__)

Reply

Marsh Posté le 01-06-2004 à 15:32:30    

Salut,
 
en effet, j'ai surement pas toutes les bonnes bases pour me lancer dans les threads, je me suis pour l'instant servi de python uniquement pour des petits scripts d'administration (suppression/copie de fichiers, purges...), je trouve ce language très simple et très pratique pour faire ce genre d'actions.
 
Mais aujourd'hui, j'ai besoin de faire d'autres choses et c'est pourquoi je demande de l'aide.
 
Pour en revenir au problème, j'ai créé un objet avec 4 arguments mais je ne comprends pas ce que tu veux dire par "qui fournit __call__", le peu de chose que j'ai trouvé sur internet là-dessus n'ont pas été très clair.
 
Si tu pouvais détailler ?
 
 
Merci

Reply

Marsh Posté le 01-06-2004 à 18:01:14    

J'ai résolu mon problème :
 
J'ai modifier ma classe Task, qui devient ceci :

Code :
  1. class Task( threading.Thread ):
  2.     def __init__( self, action, loopdelay, initdelay, arg ):
  3.         if ( action == 'delete' ) :
  4.             self._action = lambda : self.t1(arg)
  5.         elif ( action == 'erase' ) :
  6.             self._action = lambda : self.t2(arg)
  7.            
  8.         self._loopdelay = loopdelay
  9.         self._initdelay = initdelay
  10.         self._running = 1
  11.         threading.Thread.__init__( self )
  13.     def __repr__( self ):
  14.         return '%s %s %s' % (
  15.             self._action, self._loopdelay, self._initdelay )
  17.     def run( self ):
  18.         if self._initdelay:
  19.             time.sleep( self._initdelay )
  20.         self._runtime = time.time()
  21.         while self._running:
  22.             start = time.time()
  23.             self._action()
  24.             self._runtime += self._loopdelay
  25.             time.sleep( self._runtime - start )
  27.     def t1 ( self, arg ) :
  28.         deleteFile.wichFilesToTreate( arg )
  30.     def t2 ( self, arg ) :
  31.         deleteFile.eraseFile( arg )
  33.     def stop( self ):
  34.         self._running = 0


 
J'y ai rajouté deux fonctions, t1 et t2 qui sont mes 2 tâches (que je veux lancer plusieurs fois avec des arguments différents).
 
Et 1 paramètre qui est l'arguments que je veux passer en paramètre à t1 ou t2 selon l'action que je veux effectuer.
 
Maintenant je peux déclarer autant de AddTask(...) que je veux. C'est toujours t1 ou t2 qui se lancent, mais maintenant les fonctions conservent mes arguments.
 
 
Merci pour votre aide.
 
PS : Si vous avez des suggéstions, je suis toujours preneur ...

Reply

Sujets relatifs:

Leave a Replay

Make sure you enter the(*)required information where indicate.HTML code is not allowed