Event Driven System Call in Python

by

To avoid polling subprocess’ status, you could use SIGCHLD signal on Unix. To combine it with tkinter’s event loop, you could use the self-pipe trick. It also workarounds the possible tkinter + signal issue without the need to wake the event loop periodically.

#!/usr/bin/env python3
import logging
import os
import signal
import subprocess
import tkinter

info = logging.getLogger(__name__).info

def on_signal(pipe, mask, count=[0]):
    try:
        signals = os.read(pipe, 512)
    except BlockingIOError:
        return # signals have been already dealt with

    # from asyncio/unix_events.py
    #+start
    # Because of signal coalescing, we must keep calling waitpid() as
    # long as we're able to reap a child.
    while True:
        try:
            pid, status = os.waitpid(-1, os.WNOHANG)
        except ChildProcessError:
            info('No more child processes exist.')
            return
        else:
            if pid == 0:
                info('A child process is still alive. signals=%r%s',
                     signals, ' SIGCHLD'*(any(signum == signal.SIGCHLD
                                              for signum in signals)))
                return
            #+end
            # you could call your callback here
            info('{pid} child exited with status {status}'.format(**vars()))
            count[0] += 1
            if count[0] == 2:
                root.destroy() # exit GUI


logging.basicConfig(format="%(asctime)-15s %(message)s", datefmt="%F %T",
                    level=logging.INFO)
root = tkinter.Tk()
root.withdraw() # hide GUI

r, w = os.pipe2(os.O_NONBLOCK | os.O_CLOEXEC) 
signal.set_wakeup_fd(w) 
root.createfilehandler(r, tkinter.READABLE, on_signal)
signal.signal(signal.SIGCHLD, lambda signum, frame: None) # enable SIGCHLD
signal.siginterrupt(signal.SIGCHLD, False) # restart interrupted syscalls automatically
info('run children')
p = subprocess.Popen('sleep 4', shell=True)
subprocess.Popen('sleep 1', shell=True)
root.after(2000, p.send_signal, signal.SIGSTOP) # show that SIGCHLD may be delivered
root.after(3000, p.send_signal, signal.SIGCONT) # while the child is still alive
root.after(5000, lambda: p.poll() is None and p.kill()) # kill it
root.mainloop()
info('done')

Output

2015-05-20 23:39:50 run children
2015-05-20 23:39:51 16991 child exited with status 0
2015-05-20 23:39:51 A child process is still alive. signals=b'\x11' SIGCHLD
2015-05-20 23:39:52 A child process is still alive. signals=b'\x11' SIGCHLD
2015-05-20 23:39:53 A child process is still alive. signals=b'\x11' SIGCHLD
2015-05-20 23:39:54 16989 child exited with status 0
2015-05-20 23:39:54 No more child processes exist.
2015-05-20 23:39:54 done

More Related Contents:

  1. Running shell command and capturing the output
  2. Store output of subprocess.Popen call in a string [duplicate]
  3. Getting realtime output using subprocess
  4. Stop reading process output in Python without hang?
  5. Intercepting stdout of a subprocess while it is running
  6. “OSError: [Errno 2] No such file or directory” while using python subprocess with command and arguments
  7. What’s the best way to duplicate fork() in windows?
  8. subprocess “TypeError: a bytes-like object is required, not ‘str'”
  9. Multiprocessing : use tqdm to display a progress bar
  10. Process substitution not allowed by Python’s subprocess with shell=True?
  11. Launch a shell command with in a python script, wait for the termination and return to the script
  12. How to get output from subprocess.Popen(). proc.stdout.readline() blocks, no data prints out
  13. How do i use subprocesses to force python to release memory?
  14. Understanding python subprocess.check_output’s first argument and shell=True [duplicate]
  15. What is the difference between multiprocessing and subprocess?
  16. Break the function after certain time
  17. Executing a subprocess fails
  18. python subprocess Popen environment PATH?
  19. In Python 2.5, how do I kill a subprocess?
  20. How can I print and display subprocess stdout and stderr output without distortion?
  21. Python Subprocess: Too Many Open Files
  22. WindowsError [error 5] Access is denied
  23. Handling directories with spaces Python subprocess.call()
  24. Killing child process when parent crashes in python
  25. python subprocess with timeout and large output (>64K)
  26. Using greater than operator with subprocess.call
  27. How to terminate long-running computation (CPU bound task) in Python using asyncio and concurrent.futures.ProcessPoolExecutor?
  28. Opening a process with Popen and getting the PID
  29. Advantages of subprocess over os.system
  30. What is the subprocess.Popen max length of the args parameter?

Leave a Comment