来一个python代码(每周一个Python模块)
来一个python代码(每周一个Python模块)
2024-11-22 03:52:29  作者:阿叶阿静  网址:https://m.xinb2b.cn/sport/qth140029.html


信号是 Unix 系统中常见的一种进程间通信方式(IPC),例如我们经常操作的 kill -9 pid,这里的 -9对应的就是 SIGKILL 信号,9 就是这个信号的编号,SIGKILL 是它的名称。 由于不同版本的 *nux 的实现会有差异,具体请参照系统 API,可以使用 man 7 signal 查看所有信号的定义。

那么,信号有哪些使用场景呢?与其他进程间通信方式(例如管道、共享内存等)相比,信号所能传递的信息比较粗糙,只是一个整数。但正是由于传递的信息量少,信号也更便于管理和使用,可以用于系统管理相关的任务。例如通知进程终结、中止或者恢复等。每种信号用一个整型常量宏表示,以 SIG 开头,比如 SIGCHLD、SIGINT 等。

接收信号

Python 中使用 signal 模块来处理信号相关的操作,定义如下:

signal.signal(signalnum, handler)

signalnum 为某个信号,handler 为该信号的处理函数。进程可以无视信号,可以采取默认操作,还可以自定义操作。当 handler 为 signal.SIG_IGN 时,信号被无视(ignore);当 handler 为 singal.SIG_DFL,进程采取默认操作(default);当 handler 为一个函数名时,进程采取函数中定义的操作。

写一个小程序,来处理 ctrl c事件和 SIGHUP,也就是 1 和 2 信号。

#coding:utf-8import signalimport timeimport sysimport osdef handle_int(sig, frame): print "get signal: %s, I will quit"%sig sys.exit(0)def handle_hup(sig, frame): print "get signal: %s"%sigif __name__ == "__main__": signal.signal(2, handle_int) signal.signal(1, handle_hup) print "My pid is %s"%os.getpid() while True: time.sleep(3)

我们来测试下,首先启动程序(根据打印的 pid),在另外的窗口输入 kill -1 21838 和 kill -HUP 21838, 最后使用 ctrl c关闭程序。 程序的输出如下:

# python recv_signal.pyMy pid is 21838get signal: 1get signal: 1^Cget signal: 2, I will quit

再来看另一个函数,可以对信号理解的更加透彻:

signal.getsignal(signalnum)

根据 signalnum 返回信号对应的 handler,可能是一个可以调用的 Python 对象,或者是 signal.SIG_IGN(表示被忽略), signal.SIG_DFL(默认行为已经被使用)或 None(Python 的 handler 还没被定义)。

看下面这个例子,获取 signal 中定义的信号 num 和名称,还有它的 handler 是什么。

#coding:utf-8import signaldef handle_hup(sig, frame): print "get signal: %s"%sigsignal.signal(1, handle_hup)if __name__ == "__main__": ign = signal.SIG_IGN dfl = signal.SIG_DFL print "SIG_IGN", ign print "SIG_DFL", dfl print "*"*40 for name in dir(signal): if name[:3] == "SIG" and name[3] != "_": signum = getattr(signal, name) gsig = signal.getsignal(signum) print name, signum, gsig

运行的结果:可以看到大部分信号都是都有默认的行为。

SIG_IGN 1SIG_DFL 0****************************************SIGABRT 6 0SIGALRM 14 0SIGBUS 10 0SIGCHLD 20 0SIGCONT 19 0SIGEMT 7 0SIGFPE 8 0SIGHUP 1 <function handle_hup at 0x109371c80>SIGILL 4 0SIGINFO 29 0SIGINT 2 <built-in function default_int_handler>SIGIO 23 0SIGIOT 6 0SIGKILL 9 NoneSIGPIPE 13 1SIGPROF 27 0SIGQUIT 3 0SIGSEGV 11 0SIGSTOP 17 NoneSIGSYS 12 0SIGTERM 15 0SIGTRAP 5 0SIGTSTP 18 0SIGTTIN 21 0SIGTTOU 22 0SIGURG 16 0SIGUSR1 30 0SIGUSR2 31 0SIGVTALRM 26 0SIGWINCH 28 0SIGXCPU 24 0SIGXFSZ 25 1

常用的几个信号:

编号名称作用1SIGHUP终端挂起或者终止进程。默认动作为终止进程2SIGINT键盘中断 <ctrl c> 经常会用到。默认动作为终止进程3SIGQUIT键盘退出键被按下。一般用来响应 <ctrl d>。 默认动作终止进程9SIGKILL强制退出。 shell中经常使用14SIGALRM定时器超时,默认为终止进程15SIGTERM程序结束信号,程序一般会清理完状态在退出,我们一般说的优雅的退出

发送信号

signal 包的核心是设置信号处理函数。除了 signal.alarm() 向自身发送信号之外,并没有其他发送信号的功能。但在 os 包中,有类似于 Linux 的 kill 命令的函数,分别为:

os.kill(pid, sid)os.killpg(pgid, sid)

分别向进程和进程组发送信号。sid 为信号所对应的整数或者 singal.SIG*。

定时发出 SIGALRM 信号

它被用于在一定时间之后,向进程自身发送 SIGALRM 信号,这对于避免无限期地阻塞 I/O 操作或其他系统调用很有用。

import signalimport timedef receive_alarm(signum, stack): print('Alarm :', time.ctime())# Call receive_alarm in 2 secondssignal.signal(signal.SIGALRM, receive_alarm)signal.alarm(2)print('Before:', time.ctime())time.sleep(4)print('After :', time.ctime())# output# Before: Sat Apr 22 14:48:57 2017# Alarm : Sat Apr 22 14:48:59 2017# After : Sat Apr 22 14:49:01 2017

在此示例中,调用 sleep() 被中断,但在信号处理后继续,因此sleep()返回后打印的消息显示程序执行时间与睡眠持续时间一样长。

忽略信号

要忽略信号,请注册 SIG_IGN 为处理程序。

下面这个例子注册了两个程序,分别是 SIGINT 和 SIGUSR1,然后用 signal.pause() 等待接收信号。

import signalimport osimport timedef do_exit(sig, stack): raise SystemExit('Exiting')signal.signal(signal.SIGINT, signal.SIG_IGN)signal.signal(signal.SIGUSR1, do_exit)print('My PID:', os.getpid())signal.pause()# output# My PID: 72598# ^C^C^C^CExiting

通常 SIGINT(当用户按下 Ctrl-C 时由 shell 发送到程序的信号)会引发 KeyboardInterrupt。这个例子在它看到 SIGINT 时直接忽略了。输出中的每个 ^C 表示尝试从终端终止脚本。

从另一个终端使用 kill -USR1 72598 将脚本退出。

信号与线程

多线程环境下使用信号,只有 main thread 可以设置 signal 的 handler,也只有它能接收到 signal. 下面用一个例子看看效果,在一个线程中等待信号,并从另一个线程发送信号。

#coding:utf-8#orangleliu py2.7#thread_signal.pyimport signalimport threadingimport osimport timedef usr1_handler(num, frame): print "received signal %s %s"%(num, threading.currentThread())signal.signal(signal.SIGUSR1, usr1_handler)def thread_get_signal(): #如果在子线程中设置signal的handler 会报错 #ValueError: signal only works in main thread #signal.signal(signal.SIGUSR2, usr1_handler) print "waiting for signal in", threading.currentThread() #sleep 进程直到接收到信号 signal.pause() print "waiting done"receiver = threading.Thread(target=thread_get_signal, name="receiver")receiver.start()time.sleep(0.1)def send_signal(): print "sending signal in ", threading.currentThread() os.kill(os.getpid(), signal.SIGUSR1)sender = threading.Thread(target=send_signal, name="sender")sender.start()sender.join()print 'pid', os.getpid()# 这里是为了让程序结束,唤醒 pausesignal.alarm(2)receiver.join()# output# waiting for signal in <Thread(receiver, started 123145306509312)># sending signal in <Thread(sender, started 123145310715904)># received signal 30 <_MainThread(MainThread, started 140735138967552)># pid 23188# [1] 23188 alarm python thread_signal.py

Python 的 signal 模块要求,所有的 handlers 必需在 main thread 中注册,即使底层平台支持线程和信号混合编程。即使接收线程调用了 signal.pause(),但还是没有接收到信号。代码结尾处的 signal.alarm(2) 是为了唤醒接收线程的 pause(),否则接收线程永远不会退出。

尽管 alarms 可以在任意的线程中设置,但他们只能在 main thread 接收。

import signalimport timeimport threadingdef signal_handler(num, stack): print(time.ctime(), 'Alarm in', threading.currentThread().name)signal.signal(signal.SIGALRM, signal_handler)def use_alarm(): t_name = threading.currentThread().name print(time.ctime(), 'Setting alarm in', t_name) signal.alarm(1) print(time.ctime(), 'Sleeping in', t_name) time.sleep(3) print(time.ctime(), 'Done with sleep in', t_name)# Start a thread that will not receive the signalalarm_thread = threading.Thread( target=use_alarm, name='alarm_thread',)alarm_thread.start()time.sleep(0.1)# Wait for the thread to see the signal (not going to happen!)print(time.ctime(), 'Waiting for', alarm_thread.name)alarm_thread.join()print(time.ctime(), 'Exiting normally')# output# Sat Apr 22 14:49:01 2017 Setting alarm in alarm_thread# Sat Apr 22 14:49:01 2017 Sleeping in alarm_thread# Sat Apr 22 14:49:01 2017 Waiting for alarm_thread# Sat Apr 22 14:49:02 2017 Alarm in MainThread# Sat Apr 22 14:49:04 2017 Done with sleep in alarm_thread# Sat Apr 22 14:49:04 2017 Exiting normally

alarm 并没有中断 use_alarm() 中的 sleep。

相关文档:

https://pymotw.com/3/signal/index.html

http://orangleliu.info/2016/03/06/python-signal-module-simple-use/

http://www.cnblogs.com/vamei/archive/2012/10/06/2712683.html

  • 张家口突降冰雹致多地受损严重(张家口发布橙色冰雹)
  • 2024-11-22张家口发布橙色冰雹来源:张家口发布大风黄色预警信号张家口市气象台2022年8月30日15时10分发布大风黄色预警信号:预计未来6小时内我市(市辖区、康保、沽源、尚义、张北、万全、怀安、崇礼、赤城、宣化、阳原、蔚县、涿鹿。
  • 上海人腔调文化(上海人的口头禅)
  • 2024-11-22上海人的口头禅海话往大里说当然是吴语的一种但上海话在吴语中是很特别的,特别之处有两点,一是杂,二是新上海话是很杂的,周边地区的方言土语,松江话、苏州话、宁波话、杭州话,上海话当中都有,可谓兼吴越而有之比如“小鬼(读。
  • 涨停和跌停是什么意思(股票跌停就不能买了吗)
  • 2024-11-22股票跌停就不能买了吗股票交易过程中,为限制涨跌幅,设置一定的幅度,若达到这一幅度,即涨停或跌停并不是说涨停或跌停了就不能买卖了,只要你想买,你仍然可以排队买进,也可以在跌停板上挂单卖出手中的持股涨跌停板是证券管理部门为了。
  • 隐忍十年终于离婚了 隐忍十年仍不愿回应
  • 2024-11-22隐忍十年终于离婚了 隐忍十年仍不愿回应文|如水(富书专栏作者)最新一期的《我就是演员》上,演员李梦被几位评委问及当初参演电视剧《白鹿原》为什么中途被换角对于剧组来说,非不可抗力因素,是不会拍到一半换掉女一号的气氛一度陷入尴尬,李梦说她自己。
  • 修剪大树的树枝方法(修剪大树的树枝方法有什么)
  • 2024-11-22修剪大树的树枝方法有什么轻短截:轻剪枝条的顶梢(剪去枝条全长的1/5—1/4),主要用于花果类树木强壮枝修剪此种修剪方法在枝条在去掉顶梢后,刺激其下部多数半饱满芽的萌发,分散枝条养分,使来年园林观赏花果树类的枝条能产生更多中。
  • 商用和面机的制作(华菱最新和面机有了面点的加入)
  • 2024-11-22华菱最新和面机有了面点的加入疫情以来,国内餐饮市场风云变幻其中性价比高的中式面点始终牢牢得抓住了消费市场,各大餐饮企业纷纷试水探索新的模式,将面点这个常胜将军融入进自己原本的产品格局内,衍生出了——“咖啡面点”、“烧烤面点”、“。
  • 英雄无敌3各英雄成长(英雄无敌3天子守国门)
  • 2024-11-22英雄无敌3天子守国门首先感谢MyEncyclopedia老哥的赞赏,多谢m2w4d1一个疏忽,地上的小破城被褐色抢走了,不过换个角度想想,让褐色帮忙建设一下也是个不错的选择宝石特收了不少租子,收别人家的租子这件事简直不要。
  • 仙剑奇侠传四昆仑山拍照位置(仙剑奇侠传四拐个野人去寻仙)
  • 2024-11-22仙剑奇侠传四拐个野人去寻仙仙剑奇侠传这个IP想必大家都已耳熟能详,仙剑故事最初是以中国古代的仙妖神鬼传说为背景、以武侠和仙侠为题材做出的单机角色扮演游戏,而仙剑系列更在早期仙一、仙三的影视化播出后带动起了一波情怀,除却早期游戏。
  • 苍蝇乐队成员简历(苍蝇乐队主唱丰江舟)
  • 2024-11-22苍蝇乐队主唱丰江舟​​​(头图摄影:阿瓜)采访:王小笨、雅婷作者:雅婷编辑:王小笨和丰江舟聊天就像听一位长辈叙述他的过往,他声音熨帖,连同着桌子上咕嘟咕嘟的红枣水,心里的每一个皱褶都好像要被抚平采访是在东北四环外他的工。
  • 听过哪些高情商回答(你学会高情商回答了吗)
  • 2024-11-22你学会高情商回答了吗一、当有人夸你颜值很高/长得俊错误回答:没有没有/谢谢~正确回答:我就喜欢你这种有眼光的美女/帅哥二、别人说你有点矮呀!错误回答:我矮管你啥事?正确回答:没办法,都是被颜值压的三、别人对你说:没看你多。
  • 三荔高速事故最新消息(贵阳市通报三荔高速重大交通事故情况)
  • 2024-11-22贵阳市通报三荔高速重大交通事故情况央广网贵州9月19日消息(见习记者任振国)9月18日晚,贵阳贵安召开新冠疫情防控第十八场新闻发布会,会上,贵阳市人民政府副市长林刚通报了三荔高速重大交通事故的情况,并代表贵阳市委、市政府对遇难人员表示。