Python 3: Wie starte ich 2 Prozesse geben Sie die Antwort von dem zuerst beendet, und stoppen Sie den anderen Prozess früh

Question

Ich habe zwei Algorithmen A und B. Beide Algorithmen nehmen die gleiche Zeichenfolge als Eingabe, führen Sie die gleiche Transformation auf string und gibt eine neue Zeichenfolge zurück.

Die durchgeführte Transformation kann manchmal sehr CPU-intensiv sein, und die Algorithmen haben unterschiedliche Ansätze für das Problem. Die Algorithmen verhalten sich abhängig von der Eingabe-Zeichenkette drastisch unterschiedlich, aber ich interessiere mich nur für die Antwort, nicht für welchen Algorithmus die Transformation angewendet wird.

Ich habe einige Pseudo-Code geschrieben, um das Problem ein wenig besser zu erklären:

def process_alg1(algorithm1, input_string) 

    ans_string = algorithm1(input_string) 

    q.put(ans_string) 

def process_alg2(algorithm2, input_string) 

    ans_string = algorithm2(input_string) 

    q.put(ans_string) 


def apply_transformation(input_string): 

    q = multiprocess.Queue() 

    process_alg1(input_string) 

    process_alg2(input_string) 

    final_answer = q.get() 

    stop(slowest_process) 

Ich vermute, i-Daemon Prozesse verwenden müssen? Ich bin mir nur nicht sicher, welchen Ansatz ich überhaupt nehmen muss. Richte ich eine Pipeline zwischen Prozessen und einer Art Handler ein, die den langsameren Prozess zum Stoppen bringt? Kann ich das einfach mit Dämonen und einer Schlange machen?

Ich habe viele Beispiele für mehrere Eingaben für den gleichen Algorithmus gefunden, aber keine Beispiele für mehrere Algorithmen, die mit der gleichen Eingabe arbeiten.

Danke.

Answer 1

Hoffe das hilft. Verwenden Rohr statt Warteschlange:

def process_alg1(algorithm1, input_string) 

    ans_string = algorithm1(input_string) 

    q.put(ans_string) 

def process_alg2(algorithm2, input_string) 

    ans_string = algorithm2(input_string) 

    q.put(ans_string) 


def apply_transformation(input_string): 

    q = multiprocess.Queue() 

    p1 = process_alg1(input_string) 

    p2 = process_alg2(input_string) 

    p1.start() 
    p2.start() 

    while p1.is_alive() and p2.is_alive(): 
     print 'Both are still computing' 


    final_answer = q.get() 

    stop(p1 if p1.is_alive() else p2) 

Answer 2

Hier ist ein minimales Beispiel:

import multiprocessing as mp 
from time import sleep 
from numpy.random import randint 

def task(n, stopsignal): 
    for x in range(n): #complex computation task steps (iterations, etc.. however you break it up) 
     with stopsignal.getlock(): 
      if stopsignal.value: 
       print(mp.current_process().name + " recieved stop signal. Terminating.") 
     time.sleep(1) #complex computation 
    print(mp.current_process().name + " returned first. attempting to halt others...") 

stopsignal = mp.Value('b', 0, lock=True) #'b' for signed 8 bit int (could use other types) 
processes = [] 
for i in range(5): #start 5 processes 
    p = Process(
      target=task, 
      name="Process_{}".format(i), 
      args=(randint(5,20),stopsignal,), 
     ) 
    p.start() 
    processes.append(p) 

while True: 
    with stopsignal.getlock(): 
     if stopsignal.value: 
      break 
    for p in processes: #check each process 
     if p.exitcode is not None: #will be None until process terminates 
      with stopsignal.getlock(): #aquire rlock 
       stopsignal.value = 1 
      break 
    sleep(1) #only check every second