捕获Ctrl + C / SIGINT并在python中优雅退出多进程

Question

如何在多进程python程序中捕获Ctrl+ C，并正常退出所有进程，我需要在Unix和Windows上均可使用的解决方案。我尝试了以下方法：

import multiprocessing
import time
import signal
import sys

jobs = []

def worker():
    signal.signal(signal.SIGINT, signal_handler)
    while(True):
        time.sleep(1.1234)
        print "Working..."

def signal_handler(signal, frame):
    print 'You pressed Ctrl+C!'
    # for p in jobs:
    #     p.terminate()
    sys.exit(0)

if __name__ == "__main__":
    for i in range(50):
        p = multiprocessing.Process(target=worker)
        jobs.append(p)
        p.start()

这是可行的，但我认为这不是正确的解决方案。

Answer 1

正确的方法来处理Ctrl+C/SIGINT用multiprocessing.Pool是：

1. SIGINT在Pool创建流程之前，请忽略该流程。这样创建的子进程继承了SIGINT处理程序。
2. 创建SIGINTa之后，在父进程中还原原始处理程序Pool。
3. 使用map_async和apply_async代替阻塞map和apply。
4. 等待结果超时，因为默认阻塞将等待忽略所有信号。这是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指出的那样，在父进程中忽略信号和忽略信号之间存在时间窗口，在此期间信号可能会丢失。pthread_sigmask在父进程中使用临时阻止信号的传递可以防止信号丢失，但是在Python-2中不可用。