Démarre en même temps les processus python3

Question

J'essaie de simuler une conception producteur-consommateur en multiprocesseur Python 3. Le problème principal est que le producteur démarre mais que le consommateur ne démarre pas avant la fin du producteur (dans ce scénario, le consommateur ne démarre pas car le producteur ne finit jamais).

Voici le code:

#!/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() 

Je ne sais pas ce qui ne va pas dans mon code. Je l'ai testé à l'aide du multithreading et cela fonctionne, donc je suppose qu'il y a quelque chose que j'ai mal compris au sujet du multitraitement.

Merci.

Answer 1

Je ne suis pas sûr que votre file d'attente est un objet de mémoire partagée. Je pense que votre producteur écrit dans une file d'attente dans sa mémoire et que votre consommateur lit une file d'attente dans sa mémoire, mais ils n'ont pas la même mémoire et ne se parlent donc pas. Je pense que vous avez besoin d'un "gestionnaire" enroulé autour de lui. voir les docs. https://docs.python.org/2/library/multiprocessing.html#sharing-state-between-processes

Ou utilisez la version multitraitement d'une file d'attente. Encore une fois à partir des documents: https://docs.python.org/2/library/multiprocessing.html#exchanging-objects-between-processes