Python中的单调监管计时器

Question

我有一个Python代码，它催生了另一个过程。给孩子20秒以执行。如果那时还没有完成，则需要被杀死。

主：

#!/usr/bin/python

from subprocess import Popen, PIPE
from threading import Timer

proc = Popen(['./plugin.sh'], stdout=PIPE, stderr=PIPE, universal_newlines=True)
killer = Timer(20, proc.kill)
killer.start()

for line in proc.stdout:
    print('stdout: ' + line)

stdout, stderr = proc.communicate()

用于测试的样本无限儿童：

# cat plugin.sh
#!/bin/sh
count=1
while true; do
    echo "$(date) hello [$((count++))]"
    sleep 1
done

正常执行良好，20秒后，孩子被杀死。

stdout: Wed 01 Jun 2022 04:07:52 PM IST hello [1]
stdout: Wed 01 Jun 2022 04:07:53 PM IST hello [2]
...
stdout: Wed 01 Jun 2022 04:08:10 PM IST hello [19]
stdout: Wed 01 Jun 2022 04:08:11 PM IST hello [20]
#

现在，我希望主要程序在20秒后杀死儿童，而与系统时间更改无关。 使用当前代码，如果我手动更改系统时间，孩子的时间比20秒的津贴要少或更多。

例如，当我向后更改时间时：

stdout: Wed 01 Jun 2022 04:14:44 PM IST hello [4]
stdout: Wed 01 Jun 2022 02:59:25 PM IST hello [5]
...
stdout: Wed 01 Jun 2022 02:59:41 PM IST hello [21]
stdout: Wed 01 Jun 2022 02:59:42 PM IST hello [22]
...

在此处找到相关的讨论： https://bugs.pys.python.org/issue31267 < /a>

# python
Python 3.7.13 (default, May 27 2022, 08:39:11)
[GCC 8.4.0] on linux
Type "help", "copyright", "credits" or "license" for more information.
>>> import sys
>>> sys.thread_info
sys.thread_info(name='pthread', lock='semaphore', version='NPTL 2.30')
>>>

我在Linux上，使用的锁定是信号量，而不是Mutex+Cond。

我可以用来使计时器独立于系统时间更改的替代机制？

Answer 1

该API支持超时，并且似乎不受系统时间更改影响。 https:///docs.python.org/3/library/subprocess。 html＃subprocess.run

import subprocess

try:
    proc = subprocess.run(['./plugin.sh'],
            stdout=subprocess.PIPE,
            stderr=subprocess.PIPE,
            universal_newlines=True,
            timeout=10)
    for line in proc.stdout.splitlines():
        print('Plugin stdout: ' + line)

except subprocess.TimeoutExpired as t:
    for line in t.stdout.decode().splitlines():
        print('Plugin stdout: ' + line)
    print('Timed out')