使用多处理池时python SIGTERM不工作

Question

按预期更正代码：从多处理导入池导入信号导入时间导入操作系统

def consumer(i):
    while True:
        # print os.getpid()
        pass
def handler(signum, frame):
    print 'Here you go'

signal.signal(signal.SIGTERM, handler)
p = Pool(5)
p.map_async(consumer, [1 for i in range(5)])

while True:
    pass

p.terminate()
# p.close()
p.join()

==================================================

我发现了问题，当我使用map函数时，主func被阻塞，只有map函数被funish时才会调用信号处理程序。所以，使用"map_async"函数来解决这个问题要好得多。

以下是我的发现：

纯用C语言实现的长时间运行的计算（例如对大量文本进行正则表达式匹配）可能会在任意时间内不间断地运行，而不管接收到什么信号。计算完成后，将调用Python信号处理程序。

==================================================

我写了一个如下的程序，当我在终端中输入“kill pid”时，我希望在程序中退出/（如程序打印字符串），但它不起作用。有没有其他策略可以阻止SIGTERM进入主功能区。

from multiprocessing import Pool
import signal
import time
import os

def consumer(i):
    while True:
        # print os.getpid()
        pass
def handler(signum, frame):
    print 'Here you go'

signal.signal(signal.SIGTERM, handler)
p = Pool(5)
p.map(consumer, [1 for i in range(5)])

p.terminate()
# p.close()
p.join()

Answer 1

您需要使用map_async方法作为mapone块，直到结果尚未就绪。因此，在您的示例中，terminate的调用永远不会到达。