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

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

分类:python · 发布时间:2021-11-04 08:57 · 阅读:7584

这篇文章主要介绍了Python程序暂停的实现代码,非常不错,具有一定的参考借鉴价值,需要的朋友可以参考下

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

如果用sleep() 进程将阻塞

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

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

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

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


 Process: import threading from time import ctime, sleep import ThreadInReadAndWriteProblem import multiprocessing import os class 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&Writer import threading from time import ctime, sleep import os mutex = 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 ThreadInReadAndWriteProblem import SingleProcessSchedulerMultiprocess import psutil import Scheduler from time import ctime, sleep def 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程序暂停的正常处理方法,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对html中文网网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!

标签:
Python 程序 暂停

相关文章

Python轻松管理与操作文件的技巧分享

在日常开发中,我们经常会遇到需要对文件进行操作的场景,如读写文件、文件夹操作等。本文将为大家介绍一些 Python 中处理文件的实用技巧,让你的工作更高效

pytorch实现梯度下降和反向传播图文详细讲解

这篇文章主要介绍了pytorch实现梯度下降和反向传播,反向传播的目的是计算成本函数C对网络中任意w或b的偏导数。一旦我们有了这些偏导数,我们将通过一些常数α的乘积和该数量相对于成本函数的偏导数来更新网络中的权重和偏差

深入理解pytorch库的dockerfile

这篇文章主要介绍了pytorch库的dockerfile,主要包括dockerfile命令,使用指令的注意点及存在的一些问题,本文给大家介绍的非常详细,需要的朋友可以参考下

Selenium多窗口切换解决方案

本文主要介绍了Selenium多窗口切换解决方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧

Python自动化办公之定时发送邮件的实现

python中的schedule模块可以使我们方便简单的使用定时任务,即在特定的时间自动的执行一些任务的功能,本文将用这一模块实现邮件自动发送,需要的可以参考一下

返回分类 返回首页