小编Aar*_*son的帖子

Python重新加载/重新获取异常

我想知道在python中是否有可能在一个除了块之外引发异常并在稍后的块中捕获它.我相信其他一些语言默认会这样做.

这就是它的样子"

try:
   something
except SpecificError as ex:
   if str(ex) = "some error I am expecting"
      print "close softly"
   else:
      raise
except Exception as ex:
   print "did not close softly"
   raise
Run Code Online (Sandbox Code Playgroud)

我希望在else子句中使用raise来触发final语句.

实际上我不打印任何东西,只记录它,我想记录更多的情况,这是我不期望的错误消息.但是,这个额外的日志记录将包含在最终的日志中.

我相信一个解决方案是创建一个函数,如果它没有软关闭,在最后的except和else子句中调用.但这似乎没必要.

python exception raise

13
推荐指数
2
解决办法
1万
查看次数

python多处理守护进程中的僵尸进程

在研究了python守护进程之后,这个步骤似乎是最强大的:http://www.jejik.com/articles/2007/02/a_simple_unix_linux_daemon_in_python/

现在我正在尝试在守护进程类中实现一个工作池,我认为它正在工作(我还没有彻底测试代码),除了在关闭时我得到一个僵尸进程.我已经读过我需要等待来自孩子的返回代码,但我还是看不出我到底需要做什么.

以下是一些代码段:

def stop(self):
    ...
    try:
        while 1:
            self.pool.close()
            self.pool.join()
            os.kill(pid, SIGTERM)
            time.sleep(0.1)
    ...
Run Code Online (Sandbox Code Playgroud)

在这里,我尝试os.killpg了一些os.wait方法,但没有任何改进.之前和之后我也玩过closing/ joining游泳池os.kill.这个循环,它永远不会结束,一旦它到达os.kill我得到一个僵尸进程.self.pool = Pool(processes=4)发生在__init__守护程序的部分中.从run(self)之后start(self),我会打电话self.pool.apply_async(self.runCmd, [cmd, 10], callback=self.logOutput).但是,我想在讨论之前解决这个僵尸进程.

如何在守护进程中正确实现池以避免这个僵尸进程?

python daemon multiprocessing zombie-process

5
推荐指数
1
解决办法
6522
查看次数

守护进程内的Python多处理池

我针对这个问题提出了一个问题,但没有得到足够彻底的答案来解决该问题(很可能是由于在解释我的问题时缺乏严谨性,这正是我试图纠正的):Zombie process in python multiprocessing daemon

我正在尝试实现一个 python 守护进程,它使用工作池来使用Popen. 我从http://www.jejik.com/articles/2007/02/a_simple_unix_linux_daemon_in_python/借用了基本守护进程

我只改变了init, daemonize(或同样的start) 和stop方法。以下是该方法的更改init

def __init__(self, pidfile):
#, stdin='/dev/null', stdout='STDOUT', stderr='STDOUT'):
    #self.stdin = stdin
    #self.stdout = stdout
    #self.stderr = stderr
    self.pidfile = pidfile
    self.pool = Pool(processes=4)
Run Code Online (Sandbox Code Playgroud)

我没有设置 stdin、stdout 和 stderr,以便我可以使用 print 语句调试代码。另外,我尝试将此池移动到几个地方,但这是唯一不会产生异常的地方。

以下是该方法的更改daemonize

def daemonize(self):
    ...

    # redirect standard file descriptors
    #sys.stdout.flush()
    #sys.stderr.flush()
    #si = open(self.stdin, 'r')
    #so = open(self.stdout, 'a+')
    #se = open(self.stderr, 'a+', 0) …
Run Code Online (Sandbox Code Playgroud)

python multithreading pool multiprocessing threadpool

5
推荐指数
1
解决办法
4889
查看次数