Comment résoudre l'erreur « Les objets de file d'attente ne doivent être partagés qu'entre les processus par héritage » en multitraitement ?

Gestion des files d'attente partagées avec le multitraitement

Dans le module multitraitement de Python, la création d'une file d'attente partagée entre les processus nécessite une attention particulière lors de l'utilisation de multiprocessing.apply_async() pour démarrer des processus de travail asynchrones. Le "Les objets de file d'attente ne doivent être partagés qu'entre les processus par héritage." Une erreur se produit lors de la tentative de transmission d'une file d'attente directement aux processus de travail.

Pour résoudre ce problème, utilisez multiprocessing.Manager pour gérer la file d'attente et la rendre accessible aux processus de travail. multiprocessing.Manager fournit des méthodes pour créer des objets gestionnaires qui contrôlent et sérialisent différents types de données dans un segment de mémoire partagée.

L'extrait de code suivant montre comment partager une file d'attente entre plusieurs processus de travail à l'aide de multiprocessing.Manager :

<code class="python">import multiprocessing

def worker(name, que):
    que.put("%d is done" % name)

if __name__ == '__main__':
    pool = multiprocessing.Pool(processes=3)
    m = multiprocessing.Manager()
    q = m.Queue()
    workers = pool.apply_async(worker, (33, q))</code>

Dans cet exemple, multiprocessing.Manager() crée un objet gestionnaire (m) qui gère les données partagées et fournit des objets proxy qui peuvent être transmis aux processus de travail. En appelant m.Queue(), nous créons une file d'attente gérée par le gestionnaire, accessible à tous les processus de travail. Le gestionnaire sérialise ensuite l'objet proxy et le transmet au travailleur, lui permettant de communiquer avec la file d'attente partagée en toute sécurité.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!