Interrupt Python Multiprocessing.Process mit Signalen in Windows

Question

Ich habe ein Python-Skript, das einen neuen Prozess mit Multiprocessing.Process-Klasse erzeugt. Dieser Prozess soll für immer laufen, um Dinge zu überwachen. Unter Unix kann ich jetzt os.kill() verwenden, um ein Signal an diesen spezifischen Prozess zu senden, und signal.signal (...) innerhalb dieses Prozesses, um meinen speziellen Interrupt-Handler zu implementieren. Unter Windows funktionieren die Dinge nicht.

Ich lese, wie es mit popen funktioniert. Kann ich das CREATE_NEW_PROCESS_GROUP-Flag für die Process-Klasse auch angeben? und wie?

hier ist mein Beispielcode:

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

ich eine Abhilfe gefunden, sorta Implementierung Signalisierungs multiprocessing.Event Klasse.

Der Hinweis war dann interrupt_main() Methode zu finden, die in dem Hauptfaden hebt KeybordInterrupt (die entweder in thread (Python2) oder _thread (Python3) ist), die der Prozess I zu unterbrechen will, ist.

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