windows下如何实现精确控制暂停恢复子线程

zerocq

在不修改工程子线程代码的情况下,主线程有没有什么办法可以直接暂停恢复子线程

用的是windows + python2.5 + pyqt,子线程用的是qthread类


qthread的sleep好像不太好用,精度太低了


windows api里有一个暂停和恢复线程用的api能不能用来控制子线程,如果能用该如何查找子线程的句柄

ghostwwl

废话不说 这是我08年的时候的代码 翻到的

1. 
   
2. #!/usr/bin/env python
   
3. #-*- coding: utf-8 -*-
   
4. 
   
5. #****************************************************
   
6. #  FileName: GThread.py
   
7. #  Author: ghostwwl
   
8. #  Note:
   
9. #    2008.10 add states and add Class_Timer
   
10. #****************************************************
    
11. 
    
12. import time
    
13. import threading
    
14. from timeit import default_timer
    
15. 
    
16. __author__ = "ghostwwl (ghostwwl@gmail.com)"
    
17. __version__ = "1.0"
    
18. 
    
19. #-------------------------------------------------------------------------------
    
20. class Thread_Control(object):
    
21.     '''The Control Class'''
    
22.     def __init__(self):
    
23.         self.ControlEvent = threading.Event()
    
24.         self.ControlEvent.set()
    
25.         self.TimeOut = None
    
26.         self.Terminated = False
    
27.         self.CStateInfo = {-1:'STOP', 0:'READY', 1:'RUNNING', 2:'PAUSE'}
    
28.         self.CSTATES = 0
    
29.    
    
30.     def stop(self):
    
31.         self.CSTATES = -1
    
32.         print 'WARNING %s] Stopping Thread %-30s [ OK ]' % (time.strftime("%Y-%m-%d %H:%M:%S"),
    
33.                                                              self.getName())
    
34.         self.Terminated = True
    
35.         
    
36.     def pause(self, TimeOut = None):
    
37.         self.TimeOut = TimeOut
    
38.         self.ControlEvent.clear()
    
39.         self.CSTATES = 2
    
40.         
    
41.     def restore(self):
    
42.         self.ControlEvent.set()
    
43. 
    
44. #-------------------------------------------------------------------------------
    
45. class mythread(threading.Thread, Thread_Control):
    
46.     '''
    
47.     BaseThread Class With Control Method[stop, pause, restore]
    
48.     time dilution of precision about 1 millisecond
    
49.     thread state {-1:'STOP', 0:'READY', 1:'RUNNING', 2:'PAUSE'}
    
50.     '''
    
51.    
    
52.     def __init__(self, owner, ThreadName, TimeSpacing=0, TimeDelay = 0):
    
53.         '''
    
54.         __init__(self, owner, ThreadName, TimeSpacing=0)
    
55.         owner         The Thread Owner
    
56.         ThreadName    The Thread Name
    
57.         TimeSpacing   Run TimeSpacing
    
58.         TimeDelay     The Thread Start TimeDelay
    
59.         '''
    
60.         self.owner = owner
    
61.         self.TimeSpacing = TimeSpacing #任务多长时间执行一次
    
62.         self.TimeDelay = TimeDelay
    
63.         Thread_Control.__init__(self)
    
64.         threading.Thread.__init__(self, name = ThreadName)
    
65.         self.setDaemon(1)
    
66.         
    
67.     def run(self):
    
68.         '''
    
69.         This While loop stop until Terminated
    
70.         This Object Has sotp, pause(timeout = None) and restore method
    
71.         '''
    
72.         if self.TimeDelay != 0:
    
73.             TSTART = self.TimeDelay
    
74.         else:
    
75.             TSTART = 0
    
76.         while 1:
    
77.             try:
    
78.                 #这里是线程的停止处理
    
79.                 if self.Terminated:
    
80.                     break
    
81.                
    
82.                 #这里是线程的暂停处理
    
83.                 if self.TimeOut is not None:
    
84.                     #带有暂停超时的处理
    
85.                     self.ControlEvent.wait(self.TimeOut)
    
86.                     self.TimeOut = None
    
87.                     self.ControlEvent.set()
    
88.                 else:
    
89.                     #不带超时 那么必须等到线程恢复
    
90.                     self.ControlEvent.wait()
    
91.                
    
92.                 CUR_TIMING = default_timer()
    
93.                 if CUR_TIMING - TSTART > self.TimeSpacing:
    
94.                     TSTART = CUR_TIMING
    
95.                     #这个才是我们的工作函数
    
96.                     self.CSTATES = 1
    
97.                     self.handle()
    
98.                     
    
99.                 time.sleep(0.001) #暂停1毫秒 防止空跑占用过高cpu
    
100.             except Exception, e:
     
101.                 print "ERROR %s] %s Error: %s" % (time.strftime("%H:%M:%S"), self.getName(), str(e))
     
102.    
     
103.     def handle(self):
     
104.         '''The Real Work Function'''
     
105.         pass
     
106.    
     
107.     def getstate(self):
     
108.         '''check the thread state'''
     
109.         return self.CSTATES
     
110.    
     
111.     def getstatemsg(self):
     
112.         return self.CStateInfo[self.CSTATES]
     
113. 
     
114. 
     

复制代码