Python не может убить процесс

Question

У меня есть следующий код Python:

main(): 
    t1 = Thread(target=consumer, args=(q,)) 

    t2 = Thread(target=server, args=(q,)) 
    t1.start() 
    t2.start() 

def server(q): 
    while(1): 

    # Produce some data 
    data = s.recv(1000) 
    q.put(data) 
def consumer(in_q): 
    while True: 
     data = in_q.get() 

     if(data.__len__() >0): 
      pieces = data.split("\t") 

      if 'L' in pieces[0]: 
       l = multiprocessing.Process(target=fun1()) 
       l.start() 
       n.terminate() 
       n.join() 

      elif 'N' in pieces[0]: 
       n = multiprocessing.Process(target=fun2()) 
       n.start() 
       l.terminate() 
       l.join() 
def func1(): 
while(1): 
    //Do something 


def func2(): 
while(1): 
    //Do something code here 

Я хочу, чтобы убить или остановить процесс «л», когда «п» работает и наоборот. Я пробовал .terminate(), но я не мог убить процесс.

Является ли многопроцессорным способом правильным способом? Может ли кто-нибудь сказать мне, пожалуйста, что мне не хватает? Любые намеки приветствуются.

Answer 1

Решение вашей проблемы зависит от материала, что ваши процессы l и n делают (=> Ваши функции func1 и func2.

В вашем примере вы имеете while функцию в каждом, так что можно использовать контролировать свой процесс. в вашем случае вы можете злоупотреблять multiprocessing.event. он предназначен для приостановки процессов, не прекращать их. Но она должна работать в соответствии с требованиями.

import multiprocessing as mp 
def consumer(in_q): 
    #create events for communication with processes, initialized as 'False' 
    event_n = mp.event() 
    event_l = mp.event() 
    while True: 
     data = in_q.get() 

     if(data.__len__() >0): 
      pieces = data.split("\t") 

      if 'L' in pieces[0]: 
       l = multiprocessing.Process(target=func1, args=event_l) 
       l.start() 
       event_n.set() #set True and signal process n to stop 
       n.join() 

      elif 'N' in pieces[0]: 
       n = multiprocessing.Process(target=func2, args=event_n) 
       n.start() 
       event_l.set() #set True and signal process l to stop 
       l.join() 

def func1(event_l): 
    while(!event_l): #do as long event_l == False 
     //Do something 
    event_l.clear() #set false 
    return 


def func2(event_n): 
    while(!event_n): #do as long event_n == False 
     //Do something code here 
    event_n.clear() #set false 
    return 

Однако ваше смешивание потоков и процессов questi onable. Ваш server и ваш consumer находятся в одном процессе, а ваши func1 и func2 - это отдельные процессы. Это ваше намерение?