Python 3 : 2 개의 프로세스를 시작하려면 어떻게 시작합니까? 먼저 끝나면 응답을 반환하고 다른 프로세스는 일찍 종료합니다.

Question

두 개의 알고리즘 A와 B가 있습니다. 두 알고리즘 모두 입력과 ​​동일한 문자열을 사용하고 문자열을 반환하고 새 문자열을 반환합니다.

수행되는 변환은 매우 CPU 집약적 일 수 있으며 알고리즘에는 문제에 대한 다른 접근 방식이 있습니다. 알고리즘은 입력 문자열에 따라 크게 다르게 수행하지만, 어떤 알고리즘이 변환을 적용하는지에 대한 대답은 신경 쓰지 않습니다.

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) 

내가 데몬 프로세스를 사용해야합니다 같은데요 :

은 좀 더 문제를 설명하기 위해 일부 사이비 코드를 작성했습니다? 나는 어떤 접근을해야할지 모르겠다. 프로세스와 느린 프로세스를 멈추게하는 일종의 핸들러 사이에 파이프 라인을 설정합니까? 데몬과 대기열을 사용하여이 작업을 수행 할 수 있습니까?

동일한 알고리즘에 대해 여러 입력에 대한 예제가 많이 있지만 동일한 입력으로 작동하는 여러 알고리즘에 대한 예제가 없습니다.

감사합니다.

Answer 1

희망이 도움이됩니다. 대신 큐의 사용 파이프 :

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

여기에 최소한의 예입니다 :

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