n 초 후

Question

내 파이썬 코드를 파이썬에서 함수 호출을 종료하는 것은 다음과 같이 진행됩니다 등등

def a(): 
    ... 
    ... 
    subprocess.call() 
    ... 
    ... 

def b(): 
    ... 
    ... 

하고 있습니다.

내 작업 :
1) 3 초 내에 subprocess.call() 반환, 내 실행이 순간을 subprocess.call() 수익을 계속해야합니다.
2) subprocess.call()이 3 초 이내에 반환되지 않으면 subprocess.call()을 종료해야하고 3 초 후에 실행을 계속해야합니다.
3) subprocess.call()이 반환되거나 3 초가 끝날 때까지 추가 실행이 발생하지 않아야합니다.

이것은 스레드로 수행 할 수 있지만 어떻게 수행 할 수 있습니까? 실제 코드의

관련 부분은 다음과 같이 진행됩니다

... 
cmd = ["gcc", "-O2", srcname, "-o", execname];  
p = subprocess.Popen(cmd,stderr=errfile)//compiling C program 
... 
... 
inputfile=open(input,'w') 
inputfile.write(scanf_elements) 
inputfile.close() 
inputfile=open(input,'r') 
tempfile=open(temp,'w') 
subprocess.call(["./"+execname,str(commandline_argument)],stdin=inputfile,stdout=tempfile); //executing C program 
tempfile.close() 
inputfile.close() 
... 
... 

내가 컴파일하고 파이썬을 사용하여 C 프로그램을 실행하려합니다. subprocess.call()을 사용하여 C 프로그램을 실행할 때 C 프로그램에 무한 루프가 포함되어 있다고 가정하면 subprocess.call()은 3 초 후에 종료되어야하고 프로그램은 계속 진행되어야합니다. subprocess.call()이 강제 종료되었거나 성공적으로 실행 되었기 때문에 다음 코드에서 메시지를 적절하게 인쇄 할 수 있는지 여부를 알 수 있어야합니다.

백엔드 gcc는 Linux 용입니다. 당신이 call (당신이 gcc를 실행하는 동일한 방식) 대신 Popen 생성자에 전화를 변환하고자하는 경우

Answer 1

:

import subprocess 
import threading 
import time 


def process_tree_kill(process_pid): 
    subprocess.call(['taskkill', '/F', '/T', '/PID', process_pid]) 

def main(): 
    cmd = ["gcc", "-O2", "a.c", "-o", "a"]; 
    p = subprocess.Popen(cmd) 
    p.wait() 
    print "Compiled" 
    start = time.time() 

    process = subprocess.Popen("a",shell=True) 
    print(str(process.pid)) 

    # terminate process in timeout seconds 
    timeout = 3 # seconds 
    timer = threading.Timer(timeout, process_tree_kill,[str(process.pid)]) 
    timer.start() 

    process.wait() 
    timer.cancel() 

    elapsed = (time.time() - start) 
    print elapsed 

if __name__=="__main__": 
    main() 

Answer 2

이 접근하는 다음 방법 중 하나는 3 초 정도 기다리 서브 프로세스를 폴링하고 행동을 기반으로 걸릴 것입니다 해당 returncode 속성이 여전히 None인지 여부. 다음과 같은 매우 인위적인 예를 고려해

import sys 
import time 
import logging 
import subprocess 

logging.basicConfig(format='%(asctime)s %(levelname)s %(message)s', level=logging.INFO) 

if __name__ == '__main__': 
    logging.info('Main context started') 
    procCmd = 'sleep %d' % int(sys.argv[1]) 
    proc = subprocess.Popen(procCmd.split()) 

    time.sleep(3) 
    if proc.poll() is None: 
    logging.warning('Child process has not ended yet, terminating now') 
    proc.terminate() 
    else: 
    logging.info('Child process ended normally: return code = %s' % str(proc.returncode)) 

    logging.info('Main context doing other things now') 
    time.sleep(5) 
    logging.info('Main context ended') 

을 그리고 이것은 자식 프로세스가 3 초 없습니다 이내에 완료 여부에 따라 다른 로깅 출력 결과 :이 방법은 위의 항상 3을 대기하는

가

$ python parent.py 1 
2015-01-18 07:00:56,639 INFO Main context started 
2015-01-18 07:00:59,645 INFO Child process ended normally: return code = 0 
2015-01-18 07:00:59,645 INFO Main context doing other things now 
2015-01-18 07:01:04,651 INFO Main context ended 
$ python parent.py 10 
2015-01-18 07:01:05,951 INFO Main context started 
2015-01-18 07:01:08,957 WARNING Child process has not ended yet, terminating now 
2015-01-18 07:01:08,957 INFO Main context doing other things now 
2015-01-18 07:01:13,962 INFO Main context ended 

주 서브 프로세스가 그보다 더 빨리 완료 되더라도 몇 초가 걸립니다. 위의 내용을 다른 동작을 원할 경우 하위 프로세스를 계속 폴링하는 루프와 같은 것으로 변환 할 수 있습니다. 얼마나 많은 시간이 경과했는지 추적하면됩니다.

Answer 3

#!/usr/bin/python 

import thread 
import threading 
import time 
import subprocess 
import os 

ret=-1 

def b(arg): 
    global ret 
    ret=subprocess.call(arg,shell=True); 

thread.start_new_thread(b,("echo abcd",)) 
start = time.time() 


while (not (ret == 0)) and ((time.time() - start)<=3): 
    pass 

if (not (ret == 0)) : 
    print "failed" 
    elapsed = (time.time() - start) 
    print elapsed 
    thread.exit() 

elif (ret == 0):#ran before 3 sec 
    print "successful" 
    elapsed = (time.time() - start) 
    print elapsed 

나는 위의 모든 코드를 작성하고 작동하는 코드를 작성했습니다. 링크 https://docs.python.org/2/library/thread.html 메시지 :

thread.exit() SystemExit 예외를 발생시킵니다. 잡히지 않으면 스레드가 자동으로 종료됩니다.

그래서 고아 프로세스, 차단 된 리소스 등의 문제가 없어야한다고 생각해주십시오.

Answer 4

내 작업 :
1) 만약 subprocess.call() 3 초 내에 반환, 내 실행이 순간 subprocess.call() 반환을 계속해야합니다.
2) subprocess.call()이 3 초 이내에 반환되지 않으면 subprocess.call()이 종료되어야하고 3 초 후에 실행이 이되어야합니다.
3) subprocess.call()이 반환하거나 3 초가 끝날 때까지 추가 실행이 발생하지 않아야합니다.

* nix에서 스크립트에

, 당신은 signal.alarm()-based solution 사용할 수 있습니다 아래의 코드는 일을 마지막으로

import subprocess 
import threading 

# start process 
process = subprocess.Popen(*your_subprocess_call_args) 

# terminate process in 3 seconds 
def terminate(): 
    if process.poll() is None: 
     try: 
      process.terminate() 
     except EnvironmentError: 
      pass # ignore 

timer = threading.Timer(3, terminate) 
timer.start() 
process.wait() 
timer.cancel()