Abruf eines Subprozesses mit Hilfe von pid

Question

Ich habe ein Django-Projekt, in dem ein Benutzer mehrere Subprozesse gleichzeitig starten kann. Die Prozesse können einige Zeit dauern und somit kann der Benutzer mit anderen Aspekten der App weiterarbeiten. In jedem Fall kann der Benutzer alle laufenden Prozesse ansehen und einen von ihnen abfragen, um zu überprüfen, ob es vorbei ist. Dafür muss ich den Prozess mit seiner PID abfragen. Popen.poll() erwartet ein subprocess.Peopen-Objekt, während alles, was ich habe, die PID dieses Objekts ist. Wie kann ich das gewünschte Ergebnis erzielen?

in models.py:

class Runningprocess(models.Model): 
    #some other fields 
    p_id=models.CharField(max_length=500) 
    def __str__(self): 
     return self.field1 

In views.py:

def run_process(): 
    .... 
    p= subprocess.Popen(cmd, shell =True, stdout=subprocess.PIPE, stderr=subprocess.STDOUT) 
    new_p=Runningprocess() 
    new_p.p_id=p.pid 
    .... 
    new_p.save() 
    return HttpResponseRedirect('/home/') 

def check(request,pid): 
    #here i want to be able to poll the subprocess using the p_id e.g something like: 
    checkp = pid.poll() #this statement is wrong 
    if checkp is None: 
      do something 
    else: 
      do something else 

Ich brauche nur eine gültige Anweisung anstelle von 'checkp = pid.poll()'

Answer 1

Nicht mit PID abfragen

PID ist eine temporäre ID zugewiesen zu einem Prozess. Es bleibt solange in einem Prozess, wie der Prozess läuft. Wenn ein Prozess entweder beendet oder beendet wird, kann seine PID (oder nicht sofort) einem anderen Prozess zugewiesen werden. So kann eine PID eines Prozesses, die jetzt gültig ist, nach einiger Zeit nicht mehr gültig bleiben.

Jetzt, wie für einen Prozess abzufragen?

Dies ist, was ich in einem meiner Projekt tat:

psub = subprocess.Popen(something) 
# polling 

while psub.poll() is None: 
    pass 

aber der obige Code passen sie auf, könnte eine Sackgasse führen in. Um Deadlock zu vermeiden, können Sie zwei Ansätze verwenden:

1. Zähler verwenden. Wenn der Zählerwert größer als ein fester Wert wird, beenden Sie den Prozess.

2. Timeout verwenden. Erhalten Sie die Startzeit, wenn der Prozess gestartet wurde und wenn der Prozess länger dauert als eine festgelegte Zeit - Kill.

start_time = time.time() 
timeout = 60 # 60 seconds 
while psub.poll() is None: 
    if time.time() - start_tym >= int(timeout): 
     psub.kill()