python线程HelloWorld

bleem1998

改变num的值可以控制线程的数量
弄它几千个不是问题
呵呵
每个线程启动后会随机睡眠1-3秒
醒来后结束

1. 
   
2. #!/usr/bin/env python
   
3. import threading
   
4. import time
   
5. import random
   
6. 
   
7. class PrintThread(threading.Thread):
   
8.     def __init__(self, threadName):
   
9.         threading.Thread.__init__(self, name = threadName)
   
10.         self.sleepTime = random.randint(1,3)
    
11.         print "Name: %s; sleep: %d" % (self.getName(), self.sleepTime)
    
12. 
    
13.     def run(self):
    
14.         print "%s going to sleep for %s second(s)"\
    
15.               % (self.getName(), self.sleepTime)
    
16.         time.sleep(self.sleepTime)
    
17.         print self.getName(), 'done sleeping'
    
18. 
    
19. num=10
    
20. threadList=[]
    
21. for i in range(1,num+1):
    
22.     thread = PrintThread('thread'+str(i))
    
23.     threadList.append(thread)
    
24. 
    
25. print '\nStarting threads'
    
26. 
    
27. for i in threadList:
    
28.     i.start()
    
29. 
    
30. print 'All threads started\n'
    
31. 
    
32. for i in threadList:
    
33.     i.join()
    
34. 
    
35. print 'All threads stoped\n'
    

复制代码

bleem1998

线程同步可以用锁
现在让我们一起回到遥远的DOS时代
还是上面的程序
但是每一时刻只有一个线程可以工作
只是增加了三行代码而已

1. 
   
2. #!/usr/bin/env python
   
3. import threading
   
4. import time
   
5. import random
   
6. 
   
7. class PrintThread(threading.Thread):
   
8.     def __init__(self, threadName):
   
9.         threading.Thread.__init__(self, name = threadName)
   
10.         self.sleepTime = random.randint(1,3)
    
11.         print "Name: %s; sleep: %d" % (self.getName(), self.sleepTime)
    
12. 
    
13.     def run(self):
    
14.         lock.acquire()        #add this
    
15.         print "%s going to sleep for %s second(s)"\
    
16.               % (self.getName(), self.sleepTime)
    
17.         time.sleep(self.sleepTime)
    
18.         print self.getName(), 'done sleeping'
    
19.         lock.release()        #add this
    
20. 
    
21. num=10
    
22. threadList=[]
    
23. lock=threading.RLock()        #add this
    
24. for i in range(1,num+1):
    
25.     thread = PrintThread('thread'+str(i))
    
26.     threadList.append(thread)
    
27. 
    
28. print '\nStarting threads'
    
29. 
    
30. for i in threadList:
    
31.     i.start()
    
32. 
    
33. print 'All threads started\n'
    
34. 
    
35. for i in threadList:
    
36.     i.join()
    
37. 
    
38. print 'All threads stoped\n'
    

复制代码

dragonII

小弟新手，只想问一下，程序中的run()函数是何时被调用的，是在执行i.start()的时候吗？

bleem1998

yes
你要是把run改成run2就不执行了
可见start会调用run

瘦青蛙

线程是自动结束还是 通过join来结束的？

能否让线程持久运行？

xichen

不是通过join来结束的，如果PrintThread.run没有运行完，线程当然不会结束。你可以循环或者回调来保证程序的运行。

bleem1998

曾经有个高手告诉我python的线程不需要显示的调用join
线程的代码完了线程自己就结束了
无须理会

我觉得这个问题还是需要有高手站出来讲讲
python-thread的join和pthread的到底有什么差别

xichen

python-thread的join和pthread的到底有什么差别，这个问题我不懂！

bleem1998

是我问的不好不好意思

我记得pthread里
主线程join子线程的时候是可以让子线程传递一些数据回来
那么python的thread是否也可以做到呢

xichen

这个我没有找到相关资料，我通常的做法是在线程中操作共享变量来实现的。