- #Cree un Thread simple.
-
- #necessaire pour le thread
- import thread
- #necessaire pour attendre dans ma fonction MyThread() mais pas obligatoire du tout.
- import time
- #Je l'utilise pour stocker les informations de mes threads dan ma fonction
- import Queue
- # Le Queue bal permet a la fonction MyThread de montrer que les deux threads s'executent en meme temp.
- bal = Queue.Queue (100)
- #nb est le nombre de boucles qui vont etre executees
- nb = 10
- #ici on declare la fonction qui va etre executee par le thread.
- def MyThread(name,Time=0.2):
- for i in range(nb):
- print name, i
- bal.put ("Msg %d from %s"%(i,name))
- time.sleep (Time)
-
- #Ici on declare la fonction principale que l'on devra appeler.
- def main():
- #On lance nos threads (le premier argument est la fonction, le deuxieme est un tuple avec les arguments de cette fonction.
- thread.start_new_thread(MyThread,("Thread 1",0.20))
- thread.start_new_thread(MyThread,("Thread 2",0.20))
- for i in range (nb*2):
- msg = bal.get ()
- print "Reception message :", msg
-
- if __name__ == "__main__":
- main()
#Cree un Thread simple.
#necessaire pour le thread
import thread
#necessaire pour attendre dans ma fonction MyThread() mais pas obligatoire du tout.
import time
#Je l'utilise pour stocker les informations de mes threads dan ma fonction
import Queue
# Le Queue bal permet a la fonction MyThread de montrer que les deux threads s'executent en meme temp.
bal = Queue.Queue (100)
#nb est le nombre de boucles qui vont etre executees
nb = 10
#ici on declare la fonction qui va etre executee par le thread.
def MyThread(name,Time=0.2):
for i in range(nb):
print name, i
bal.put ("Msg %d from %s"%(i,name))
time.sleep (Time)
#Ici on declare la fonction principale que l'on devra appeler.
def main():
#On lance nos threads (le premier argument est la fonction, le deuxieme est un tuple avec les arguments de cette fonction.
thread.start_new_thread(MyThread,("Thread 1",0.20))
thread.start_new_thread(MyThread,("Thread 2",0.20))
for i in range (nb*2):
msg = bal.get ()
print "Reception message :", msg
if __name__ == "__main__":
main()