Python程序暂停的正常处理方法

Python  /  管理员 发布于 7年前   196

将进程挂起(Suspend) 而非 阻塞(Block)

如果用sleep() 进程将阻塞

假设进程下有两个线程 那么这两个线程会继续运行

要使进程挂起 可以考虑使用psutil

import psutilp = psutil.Process(pid)p.suspend()  #挂起进程p.resume()  #恢复进程

为了证明效果 我写了一个简单的进程Process
其下有两个线程 读者Reader 和 写者Writer（简单的读者写者问题）

Process:import threadingfrom time import ctime, sleepimport ThreadInReadAndWriteProblemimport multiprocessingimport osclass Process(multiprocessing.Process):    def __init__(self):    multiprocessing.Process.__init__(self) #手动实现父类    pid = os.getpid()  def run(self):    print '当前运行进程PID : %s ' %self.pid  #子线程的id与父进程的pid相同 属于 同一个进程    for i in range(0,5):      r = ThreadInReadAndWriteProblem.Reader()      w = ThreadInReadAndWriteProblem.Writer()      w.start()      r.start() print '进程阻塞'    sleep(10)  #总共运行时间10秒Reader&Writerimport threadingfrom time import ctime, sleepimport osmutex = threading.Lock()  #互斥锁 mutex_readercount = threading.Lock() #计数时的互斥 计算当前正在读的数目readerCount = 0 number = 0#不满足条件的 进入阻塞状态class Reader(threading.Thread):    #读者  def __init__(self):    threading.Thread.__init__(self) #继承父类构造函数  def run(self):    global mutex    global readerCount    #print '线程PID: %s ' %os.getpid()    while True:       mutex_readercount.acquire()       readerCount +=1       if readerCount == 1:         print '读者进程等待中，编号%s' %(self.name)         mutex.acquire() == False   # 第一个需要申请       mutex_readercount.release()       print '开始读 , 读者编号 %s ,现在时间是 %s' %(self.name,ctime())       sleep(2)       print '完成读 , 读者编号 %s , 现在时间是 %s' %(self.name,ctime())       mutex_readercount.acquire()       readerCount -= 1       if readerCount == 0:  #所有读者均完成          print '最后一个读者完成读 '          mutex.release()       mutex_readercount.release()class Writer(threading.Thread):   #写者  def __init__(self):    threading.Thread.__init__(self)  def run(self):    global mutex    global writerCount    #print '线程PID： %s' %os.getpid()    while True:      print '写者进程等待中 编号： %s' %(self.name)      mutex.acquire() print '开始写 编号：%s 现在时间是： %s ' %(self.name,ctime())      sleep(5)      print '结束写 编号: %s 现在时间是 %s' %(self.name,ctime())      mutex.release()

测试程序

import ThreadInReadAndWriteProblemimport SingleProcessSchedulerMultiprocessimport psutilimport Schedulerfrom time import ctime, sleepdef main():  p = SingleProcessSchedulerMultiprocess.Process()  p.start()  sleep(3)  stop(p.pid)  print '进程挂起 %s' %ctime()  sleep(5)  wake(p.pid)  print '唤醒进程 %s' %ctime()def stop(pid):    print '进程暂停 进程编号 %s ' %(pid)    p = psutil.Process(pid)    p.suspend()def wake(pid):    print '进程恢复 进程编号 %s ' %(pid)    p = psutil.Process(pid)    p.resume()if __name__ == '__main__':  main()

结果：

当前运行进程PID : 3096
写者进程等待中 编号： Thread-2
开始写 编号：Thread-2 现在时间是： Mon Nov 30 21:12:12 2015
读者进程等待中，编号Thread-1
写者进程等待中 编号： Thread-4
进程阻塞
写者进程等待中 编号： Thread-6
写者进程等待中 编号： Thread-8
写者进程等待中 编号： Thread-10
进程暂停 进程编号 3096
进程挂起 Mon Nov 30 21:12:15 2015
进程恢复 进程编号 3096
唤醒进程 Mon Nov 30 21:12:20 2015
结束写 编号: Thread-2 现在时间是 Mon Nov 30 21:12:20 2015
写者进程等待中 编号： Thread-2
开始读 , 读者编号 Thread-1 ,现在时间是 Mon Nov 30 21:12:20 2015
开始读 , 读者编号 Thread-3 ,现在时间是 Mon Nov 30 21:12:20 2015
开始读 , 读者编号 Thread-5 ,现在时间是 Mon Nov 30 21:12:20 2015
开始读 , 读者编号 Thread-7 ,现在时间是 Mon Nov 30 21:12:20 2015
开始读 , 读者编号 Thread-9 ,现在时间是 Mon Nov 30 21:12:20 2015
完成读 , 读者编号 Thread-1 , 现在时间是 Mon Nov 30 21:12:22 2015
完成读 , 读者编号 Thread-3 , 现在时间是 Mon Nov 30 21:12:22 2015
完成读 , 读者编号 Thread-5 , 现在时间是 Mon Nov 30 21:12:22 2015
完成读 , 读者编号 Thread-7 , 现在时间是 Mon Nov 30 21:12:22 2015

总结

以上所述是小编给大家介绍的Python程序暂停的正常处理方法，希望对大家有所帮助，如果大家有任何疑问请给我留言，小编会及时回复大家的。在此也非常感谢大家对站的支持！
如果你觉得本文对你有帮助，欢迎转载，烦请注明出处，谢谢！