Comment partager et modifier un dictionnaire entre plusieurs processus en Python ?

Multitraitement : partage de dictionnaire inter-processus

Considérons un scénario dans lequel plusieurs processus opèrent sur une file d'attente partagée, Q, et manipulent un dictionnaire global , D. Étonnamment, accéder à D après avoir rejoint Q révèle un dictionnaire vide, malgré les modifications observées dans les processus enfants.

Ce comportement provient de problèmes de synchronisation. Chaque processus fonctionne sur son propre espace mémoire et les modifications apportées à D au sein des processus enfants ne sont pas automatiquement reflétées dans le processus principal. Pour résoudre ce problème, des mesures de synchronisation sont nécessaires.

Solution : Utiliser un objet Manager

La bibliothèque standard Python fournit une solution utilisant l'objet Manager. Cet objet offre un accès synchronisé aux données partagées entre les processus :

from multiprocessing import Process, Manager

def f(d):
    d[1] += '1'
    d['2'] += 2

if __name__ == '__main__':
    manager = Manager()

    d = manager.dict()
    d[1] = '1'
    d['2'] = 2

    p1 = Process(target=f, args=(d,))
    p2 = Process(target=f, args=(d,))
    p1.start()
    p2.start()
    p1.join()
    p2.join()

    print(d)

Dans cet exemple, la méthode dict() de l'objet Manager crée un dictionnaire partagé, d, accessible par tous les processus. Les modifications apportées à d au sein des processus enfants sont propagées au processus principal via la mémoire partagée gérée par l'objet Manager.

Sortie :

$ python mul.py
{1: '111', '2': 6}

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!