我如何知道子进程何时死亡？

发布于 2024-09-18 13:15:33 字数 456 浏览 7 评论 0原文

在我的课堂上我运行了 4 个进程。

from multiprocessing import Process

    procs = (
             Process(target=ClassOne, name='ClassOne'),
             Process(target=ClassTwo, name='ClassTwo'),
             Process(target=ClassThree, name='ClassThree'),
             Process(target=ClassFour, name='ClassFour'),
            )

    for p in procs:
        p.daemon = False
        p.start()

当我的一个子进程死亡时，我希望收到通知，这样我就可以杀死另一个进程和我自己。

原文

In my class I run 4 process.

from multiprocessing import Process

    procs = (
             Process(target=ClassOne, name='ClassOne'),
             Process(target=ClassTwo, name='ClassTwo'),
             Process(target=ClassThree, name='ClassThree'),
             Process(target=ClassFour, name='ClassFour'),
            )

    for p in procs:
        p.daemon = False
        p.start()

I would like to be notified when one of my children process died so i can kill the other and my self.

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

靑春怀旧 2024-09-25 13:15:33

只需为 SIGCHLD 定义一个信号处理程序，检查刚刚死亡的子级返回的帧以检索您需要的有关它的信息......如果需要，也可以退出（）父级:)

回复收藏 0 原文

瑾夏年华 2024-09-25 13:15:33

可以使用 os.waitpid() 传递 -1 作为第一个参数，将 0 作为第二个参数。

第一个参数意味着该请求属于当前进程的任何子进程。
第二个参数意味着它的行为类似于 wait()。

该函数返回一个元组，其中包含已死亡子进程的 pid 及其退出代码。

回复收藏 0 原文

终陌 2024-09-25 13:15:33

您可能想查看

如果您准备在代码中添加对 gobject（PyGTK 的一部分）的依赖项，那么 AutoJoiningProcess 将允许您监听进程完成时发出的信号。收到该信号后，您可以随心所欲地做出反应。

回复收藏 0 原文

小嗷兮 2024-09-25 13:15:33

最简单的方法是显式等待所有进程完成。

while multiprocessing.active_children():
    pass

这不是您可能想要的事件驱动的，但它会在您的示例中完成工作。另请确保导入多处理。

The simplest way would be to explicitly wait until all processes are done.

while multiprocessing.active_children():
    pass

This is not event driven as you might intend, but it will get the job done in your example. Also make sure you import multiprocessing.

回复收藏 0 原文

耳钉梦 2024-09-25 13:15:33

这是一个 Windows 解决方案。它使用 WaitForMultipleObjects API 调用。对于 Unix os.waitpid 可以完成这项工作。

import multiprocessing as mp
import ctypes


SYNCHRONIZE = 0x00100000
INFINITE = -1


def mbox(msg):
  ctypes.windll.user32.MessageBoxW(0, msg, u'spam', 0)


if __name__ == '__main__':

  # start 2 processes
  procs = [mp.Process(target=mbox, args=(msg,)) for msg in u'ab']
  for p in procs:
    p.start()

  # wait for at least one process to terminate
  handles = [
    ctypes.windll.kernel32.OpenProcess(SYNCHRONIZE, False, p.pid)
    for p in procs]
  array_type = ctypes.c_long * len(handles)
  handle_array = array_type(*handles)
  ctypes.windll.kernel32.WaitForMultipleObjects(
    len(handles), handle_array, False, INFINITE)

  # terminate the rest
  for p in procs:
    p.terminate()

  # exit
  print 'done'

Here is a Windows solution. It uses WaitForMultipleObjects API call. For Unix os.waitpid may do the job.

import multiprocessing as mp
import ctypes


SYNCHRONIZE = 0x00100000
INFINITE = -1


def mbox(msg):
  ctypes.windll.user32.MessageBoxW(0, msg, u'spam', 0)


if __name__ == '__main__':

  # start 2 processes
  procs = [mp.Process(target=mbox, args=(msg,)) for msg in u'ab']
  for p in procs:
    p.start()

  # wait for at least one process to terminate
  handles = [
    ctypes.windll.kernel32.OpenProcess(SYNCHRONIZE, False, p.pid)
    for p in procs]
  array_type = ctypes.c_long * len(handles)
  handle_array = array_type(*handles)
  ctypes.windll.kernel32.WaitForMultipleObjects(
    len(handles), handle_array, False, INFINITE)

  # terminate the rest
  for p in procs:
    p.terminate()

  # exit
  print 'done'

回复收藏 0 原文

~没有更多了~