동시에 시작 python3

Question

나는 파이썬 3 멀티 프로세싱에서 생산자 - 소비자 디자인을 시뮬레이션하려고한다. 주요 문제는 생산자가 시작하지만 생산자가 끝날 때까지 소비자가 시작하지 않는다는 것입니다 (이 시나리오에서는 생산자가 끝나지 않아서 소비자가 시작되지 않습니다). 내 코드에서 뭐가 잘못 됐는지 모른다

#!/usr/bin/python3 

from scapy.all import * 
from queue import Queue 
from multiprocessing import Process 

queue = Queue() 

class Producer(Process): 
    def run(self): 
     global queue 
     print("Starting producer thread") 
     sniff(iface="wlan1mon", store=0, prn=pkt_callback) 

def pkt_callback(pkt): 
    queue.put(pkt) 
    print(queue.qsize()) 

class Consumer(Process): 
    def run(self): 
     global queue 
     while True: 
      pkt = queue.get() 
      queue.task_done() 
      if pkt.haslayer(Dot11): 
       print("**Packet with Dot11 layer has been processed") 
      else: 
       print("--Packet without Dot11 layer has been processed") 



if __name__ == '__main__': 
    Producer().start() 
    Consumer().start() 

: 여기

는 코드입니다. 멀티 스레딩을 사용하여 테스트하고 작동하므로 멀티 프로세싱에 대해 잘못 이해하고있는 것 같습니다.

감사합니다.

Answer 1

대기열이 공유 메모리 개체인지 확신하지 못합니다. 나는 당신의 생산자가 그것의 기억에있는 줄에 쓰고 있고 당신의 소비자가 그것의 기억에있는 대기열에서 읽고 있다고 생각하지만, 그들은 서로 이야기하는 것이 아닌 동일한 기억이 아닙니다. 나는 당신이 그것을 감싸고있는 "매니저"를 필요로한다고 생각한다. 문서를보십시오. https://docs.python.org/2/library/multiprocessing.html#sharing-state-between-processes

또는 다중 처리 버전의 대기열을 사용하십시오. 다시 docs에서 : https://docs.python.org/2/library/multiprocessing.html#exchanging-objects-between-processes