は、Pythonマルチプロセッシングを中断します。Windowsのシグナルを使用しているプロセス

Question

私は、multiprocessing.Processクラスを使用して新しいプロセスを生成するpythonスクリプトを持っています。このプロセスは、物事を監視するために永遠に実行されるはずです。 Unixでは、os.kill（）を使用して特定のプロセスに信号を送信し、そのプロセス内のsignal.signal（...）を使用して、特定の割り込みハンドラを実装することができます。 Windowsでは動作しません。

popenを使用してそれを行う方法を読んでいます。 ProcessクラスのCREATE_NEW_PROCESS_GROUPフラグも指定できますか？そしてどうやって？ここ

は私のサンプルコードです：

import multiprocessing as mp 
import time 
import signal 
import os 
import platform 

def my_h(signal, frame): 
    print("recieved signal", signal) 
    raise InterruptedError 

def a_task(): 
    signal.signal(signal.SIGINT, my_h) 
    print("this is 'a_task'", os.getpid()) 
    try: 
     while True: 
      print(time.time()) 
      time.sleep(1) 
    except Exception as e: 
     print(type(e), e) 
    print("'a_task' is at end") 


if __name__ == '__main__': 
    p = mp.Process(target=a_task) 
    p.start() 
    time.sleep(1) 

    if platform.system() == 'Windows': 
     print("send CTRL_C_EVENT") 
     os.kill(p.pid, signal.CTRL_C_EVENT) 
    elif platform.system() == 'Linux': 
     print("send SIGINT") 
     os.kill(p.pid, signal.SIGINT) 

    time.sleep(3) 
    try: 
     os.kill(p.pid, signal.SIGTERM) 
    except: 
     pass 

Answer 1

私はみかんmultiprocessing.Eventクラスを使用してシグナリングを実装する、回避策を見つけました。

手がかりは、私が中断するプロセスであるメインスレッドでKeybordInterruptを上げる（thread（Python2）または_thread（のpython3）のいずれかである）interrupt_main()方法を見つけることが、その後でした。

import multiprocessing as mp 
import time 
import signal 
import os 
import threading 
import _thread 

def interrupt_handler(interrupt_event): 
    print("before wait") 
    interrupt_event.wait() 
    print("after wait") 
    _thread.interrupt_main() 

def a_task(interrupt_event, *args): 
    task = threading.Thread(target=interrupt_handler, args=(interrupt_event,)) 
    task.start() 

    print("this is 'a_task'", os.getpid()) 
    try: 
     while True: 
      print(time.time()) 
      time.sleep(1) 
    except KeyboardInterrupt: 
     print("got KeyboardInterrupt") 
    print("'a_task' is at end") 


if __name__ == '__main__': 
    interrupt_event = mp.Event() 
    p = mp.Process(target=a_task, args = (interrupt_event, tuple())) 
    p.start() 
    time.sleep(2) 
    print("set interrupt_event") 
    interrupt_event.set() 

    time.sleep(3) 
    try: 
     os.kill(p.pid, signal.SIGTERM) 
    except: 
     pass