Lancer un thread et passage de paramètre

Recherche :

Mot : Pseudo : Filtrer
Bas de page
Auteur	Sujet : Lancer un thread et passage de paramètre

peon3

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 :

import threading
import deleteFile
import time
class Task( threading.Thread ):
def __init__( self, action, loopdelay, initdelay ):
self._action = action
self._loopdelay = loopdelay
self._initdelay = initdelay
self._running = 1
threading.Thread.__init__( self )
def __repr__( self ):
return '%s %s %s' % (
self._action, self._loopdelay, self._initdelay )
def run( self ):
if self._initdelay:
time.sleep( self._initdelay )
self._runtime = time.time()
while self._running:
start = time.time()
self._action()
self._runtime += self._loopdelay
time.sleep( self._runtime - start )
def stop( self ):
self._running = 0
class Scheduler:
def __init__( self ):
self._tasks = []
def __repr__( self ):
rep = ''
for task in self._tasks:
rep += '%s\n' % `task`
return rep
def AddTask( self, action, loopdelay, initdelay = 0 ):
task = Task( action, loopdelay, initdelay )
self._tasks.append( task )
def StartAllTasks( self ):
for task in self._tasks:
task.start()
def StopAllTasks( self ):
for task in self._tasks:
print 'Stopping task', task
task.stop()
task.join()
print 'Stopped'
if __name__ == '__main__':
def t1() :
print "t1"
s = Scheduler()
s.AddTask(t1, 1, 0)
s.StartAllTasks()
raw_input()
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

Publicité

Taz

bisounours-codeur

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

peon3

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 :

x = "toto1"
s.AddTash(lambda : t1(x), ...)
x = "toto2"
s.AddTash(lambda : t1(x), ...)

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

Taz

bisounours-codeur

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

peon3

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

peon3

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 :

dict[i] = arg
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 :

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.

peon3

oupss :

la dernière ligne est :

AddTask(lambda : dict[i], int(arg3), int(arg4))
KeyError: 2

désolé, faute de frappe

Taz

bisounours-codeur

é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__)

peon3

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

peon3

J'ai résolu mon problème :

J'ai modifier ma classe Task, qui devient ceci :

Code :

class Task( threading.Thread ):
def __init__( self, action, loopdelay, initdelay, arg ):
if ( action == 'delete' ) :
self._action = lambda : self.t1(arg)
elif ( action == 'erase' ) :
self._action = lambda : self.t2(arg)
self._loopdelay = loopdelay
self._initdelay = initdelay
self._running = 1
threading.Thread.__init__( self )
def __repr__( self ):
return '%s %s %s' % (
self._action, self._loopdelay, self._initdelay )
def run( self ):
if self._initdelay:
time.sleep( self._initdelay )
self._runtime = time.time()
while self._running:
start = time.time()
self._action()
self._runtime += self._loopdelay
time.sleep( self._runtime - start )
def t1 ( self, arg ) :
deleteFile.wichFilesToTreate( arg )
def t2 ( self, arg ) :
deleteFile.eraseFile( arg )
def stop( self ):
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 ...

FORUM HardWare.fr

Programmation

Python

Lancer un thread et passage de paramètre

Sujets relatifs
!Urgent! Problème ASP lors passage IIS 4.0 --> 5.0	[HTML & PHP] Passage variable en adresse
[VB6] passage de variable	thread en python
variable passée en paramètre dans url	pb d'utilisation des thread sous linux - Résolu
Lancer une macro excel depuis un batch	Lancer Macro access depuis excel
[ASP + Access] Lancer un Etat Access à partir d'une page ASP	passage par référence pour objets php [OK]
Plus de sujets relatifs à : Lancer un thread et passage de paramètre

Page générée en 0.090 secondes