python-3.x - 如果父进程在 python 中崩溃,确保子进程被杀死。解决方案必须支持所有操作系统
问题描述
我有一个应用程序,其中父进程轮询服务器以获取下载作业,然后生成子进程以完成该作业。这个循环一直持续到有一些作业要由父进程处理。我需要确保子进程死亡万一父进程崩溃。我使用python作为编程语言。另外,假设这个父进程死了,它是由其他进程启动的。以下是一些机制 - 1. 根据 python 的多处理模块 - “当进程退出时,它会尝试终止其所有守护进程子进程。” 所以它尝试但不保证。所以它不可靠。2.我可以在db中添加条目,其映射为child_process_id->jobId,它告诉哪个子进程正在下载哪个作业。当父进程在轮询之前出现时,它会检查是否有 child_process_id->jobId 的条目。如果有,它会使用给定的 child_process_id 杀死进程并在下一次轮询中发送 jobId。当父进程突然崩溃时,我可以有一种干净的方法来杀死子进程吗?我需要一个兼容 windows、linux 和 mac 的解决方案。有人建议我文件锁可以帮助我,但我不明白文件锁如何帮助我实现这一目标。
解决方案
#parent.py
import time
import subprocess
import file_lock_lib
import os
PARENT_LOCK_NAME = "ParentChildTask"
CHILD_LOCK_NAME = "ChildTask-%d"
def main():
#for running single parent process
fmutex, res = file_lock_lib.FileLock(PARENT_LOCK_NAME, True)
print("PARENT ID is =============" + str(os.getpid()))
if not res:
print("ParentProcess already running")
exit(1)
print("Spawing Child Processes")
r = subprocess.Popen(["python", "/Users/abi/PycharmProjects/osProgramming/parent_child/child.py"])
#aquire the lock for child process
c_lock, res = file_lock_lib.FileLock(CHILD_LOCK_NAME% r.pid)
import time
start_time = int(time.time())
while (int(time.time()) - start_time) < 180:
a = 1
1/0
#file_lock_lib.FileUnlock(fmutex)
if __name__ == '__main__':
main()
#file_lock.lib.py
import sys
import os
if sys.platform != 'win32':
'NOOB_IDS fcntl sysv_ipc sendmsg'
import fcntl
def FileLock(fname, nb=False):
if sys.platform == 'win32':
try:
sa = w32s.SECURITY_ATTRIBUTES()
sa.SetSecurityDescriptorDacl(True, None, False)
fmutex = win32event.CreateMutex(sa, False, fname)
except pywintypes.error as fault:
if fault.winerror == 5:
fmutex = win32event.OpenMutex(win32event.SYNCHRONIZE, False, fname)
else:
raise
if nb:
wtime = 0
else:
wtime = win32event.INFINITE
rc = win32event.WaitForSingleObject(fmutex, wtime)
if rc == win32event.WAIT_TIMEOUT or rc == win32event.WAIT_FAILED:
win32api.CloseHandle(fmutex)
return None, False
else:
if not fname.startswith('/'):
# Not an absolute path name, prefix in $HOME/.inSync
fname = os.path.join(os.getenv('HOME'), '.file_lock_lib', fname)
fdir = os.path.dirname(fname)
if not os.path.exists(fdir):
os.makedirs(fdir)
try:
fmutex = open(fname, "rb+")
except:
fmutex = open(fname, "wb+")
try:
flags = fcntl.LOCK_EX
if nb:
flags |= fcntl.LOCK_NB
fcntl.flock(fmutex.fileno(), flags)
except IOError:
return None, False
return fmutex, True
def FileUnlock(fmutex):
if sys.platform == 'win32':
win32event.ReleaseMutex(fmutex)
win32api.CloseHandle(fmutex)
else:
fcntl.flock(fmutex.fileno(), fcntl.LOCK_UN)
fmutex.close()
#child.py
import time
import subprocess
import file_lock_lib
import os
PARENT_LOCK_NAME = "ParentChildTask"
CHILD_LOCK_NAME = "ChildTask-%d"
def main():
print("CHILD PID =================" + str(os.getpid()))
#check if parent process is running
fmutex, res = file_lock_lib.FileLock(PARENT_LOCK_NAME, True)
if res:
file_lock_lib.FileUnlock(fmutex)
print("Parent process is not running")
exit(1)
print("Child Started")
#spwan a thread to do work
#wait on Parent
mtx, res = file_lock_lib.FileLock(CHILD_LOCK_NAME%os.getpid())
file_lock_lib.FileUnlock(mtx)
print("Child Exited as parent process was killed")
if __name__ == '__main__':
main()
我想出了解决问题的方法。考虑上面代码中的父进程和子进程。希望这个解决方案有效....
推荐阅读
- sql - 如何使用 exists 获取产品的完整列表?
- react-native - Dialogflow 的“请求具有无效的身份验证凭据。应为 OAuth 2 访问令牌、登录 cookie 或其他有效的身份验证凭据”
- mongodb - 在字段名称中使用连字符时,似乎我无法处理来自 mongodb 的响应
- r - 缺失值和行
- tensorflow-federated - 在运行“构建您自己的联邦学习算法”教程时,Tensorflow federated (TFF) 0.19 的性能明显低于 TFF 0.17
- google-sheets - 使用来自同一列数据的多个 IFS 简化公式
- laravel - 当用户单击 donut chart.js 中的特定区域时,如何获取标签名称?我无法找到 chart.js 所选区域的索引
- jsp - Jsp 在第 9 行和第 12 行返回错误:javax.servlet.jsp.PageContext 无法解析为类型
- html - Vue.js html2canvas 正在捕获黑框
- java - 在请求正文中发送 MultipartFile 文件以及邮递员中的其他数据