用multiprocessing.Pool處理Ctrl+C/SIGINT的正確方法是：在創(chuàng)建進(jìn)程Pool之前，使進(jìn)程忽略SIGINT。這樣創(chuàng)建的子進(jìn)程繼承SIGINT處理程序。

創(chuàng)建Pool之后，還原父進(jìn)程中的原始SIGINT處理程序。

使用map_async和apply_async而不是阻塞map和apply。

等待超時的結(jié)果，因?yàn)槟J(rèn)的阻塞等待忽略所有信號。這是Python錯誤https://bugs.python.org/issue8296。

總而言之：#!/bin/env python

from __future__ import print_function

import multiprocessing

import os

import signal

import time

def run_worker(delay):

print("In a worker process", os.getpid())

time.sleep(delay)

def main():

print("Initializng 2 workers")

original_sigint_handler = signal.signal(signal.SIGINT, signal.SIG_IGN)

pool = multiprocessing.Pool(2)

signal.signal(signal.SIGINT, original_sigint_handler)

try:

print("Starting 2 jobs of 5 seconds each")

res = pool.map_async(run_worker, [5, 5])

print("Waiting for results")

res.get(60) # Without the timeout this blocking call ignores all signals.

except KeyboardInterrupt:

print("Caught KeyboardInterrupt, terminating workers")

pool.terminate()

else:

print("Normal termination")

pool.close()

pool.join()

if __name__ == "__main__":

main()

正如@YakovShklarov所指出的，從忽略信號到在父進(jìn)程中忽略它之間有一段時間，在此期間信號可能會丟失。使用pthread_sigmask代替在父進(jìn)程中臨時阻止信號的傳遞將防止信號丟失，但是，在Python-2中不可用。

總結(jié)

以上是生活随笔為你收集整理的python捕获信号退出_Python捕获信号退出Python中的捕获Ctrl+C/SIGINT，优雅地退出多个进程,python,在,CtrlCSIGINT,并...的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。