9

我想知道在终止在不同线程中启动的子进程时是否可以关闭通信管道。如果我不调用communicate()，那么kill() 将按预期工作，在一秒而不是五秒后终止进程。

我在这里找到了一个类似问题的讨论，但我没有得到真正的答案。我假设我必须能够关闭管道或显式终止子子进程（在示例中为“睡眠”）并终止它以解除管道阻塞。

我也试图在 SO 上找到她的答案，但我只找到了 this和this和this，据我所知，它们并没有直接解决这个问题（？）。

所以我想做的是能够在第二个线程中运行一个命令并获得它的所有输出，但是当我想要的时候能够立即杀死它。我可以通过一个文件并跟踪它或类似的东西，但我认为应该有更好的方法来做到这一点？

import subprocess, time
from threading import Thread

process = None

def executeCommand(command, runCommand):
    Thread(target=runCommand, args=(command,)).start()

def runCommand(command):
    global process
    args = command.strip().split()
    process = subprocess.Popen(args, shell=False, stdout=subprocess.PIPE)

    for line in process.communicate():
        if line:
            print "process:", line,

if __name__ == '__main__':
    executeCommand("./ascript.sh", runCommand)
    time.sleep(1)
    process.kill()

这是脚本：

#!/bin/bash
echo "sleeping five"
sleep 5
echo "slept five"

输出

$ time python poc.py 
process: sleeping five

real    0m5.053s
user    0m0.044s
sys 0m0.000s
4

3 回答 3

6

我认为问题在于 process.kill() 只杀死直接子进程（bash），而不是 bash 脚本的子进程。

这里描述了问题和解决方案：

使用 Popen(..., preexec_fn=os.setsid) 创建进程组，使用 os.pgkill 杀死整个进程组。例如

import os
import signal
import subprocess
import time
from threading import Thread

process = None

def executeCommand(command, runCommand):
    Thread(target=runCommand, args=(command,)).start()

def runCommand(command):
    global process
    args = command.strip().split()
    process = subprocess.Popen(
        args, shell=False, stdout=subprocess.PIPE, preexec_fn=os.setsid)

    for line in process.communicate():
        if line:
            print "process:", line,

if __name__ == '__main__':
    executeCommand("./ascript.sh", runCommand)
    time.sleep(1)
    os.killpg(process.pid, signal.SIGKILL)

$ time python poc.py 
process: sleeping five

real    0m1.051s
user    0m0.032s
sys 0m0.020s
于 2011-09-13T04:38:41.967 回答
0

在我看来，做到这一点并避开多线程问题的最简单方法是从主线程设置一个终止标志，并在通信之前在脚本运行线程中检查它，当标志是时终止脚本True.

于 2009-10-26T16:51:38.187 回答
-1

看起来您可能是 Python 超粗粒度并发的受害者。将您的脚本更改为：

#!/bin/bash
echo "sleeping five"
sleep 5
echo "sleeping five again"
sleep 5
echo "slept five"

然后输出变为：

process: sleeping five

real    0m5.134s
user    0m0.000s
sys     0m0.010s

如果整个脚本运行，时间将是 10 秒。所以看起来python控制线程直到bash脚本休眠后才真正运行。同样，如果您将脚本更改为：

#!/bin/bash
echo "sleeping five"
sleep 1
sleep 1
sleep 1
sleep 1
sleep 1
echo "slept five"

然后输出变为：

process: sleeping five

real    0m1.150s
user    0m0.010s
sys     0m0.020s

简而言之，您的代码按逻辑实现。:)

于 2009-10-26T15:30:54.683 回答