shared variables multiprocessing

Version imprimable

Bonjour à tous,

Soit le petit code suivant ou le processus père crée un dictionnaire avec Manager et le passe en args au processus fils. Ce dernier est censé ajouter des listes au dictionnaire de sorte que le tous soit partagé entre le fils et le père.
Code:

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 import multiprocessing as mp import time def modif1(d): l=[3,4] d[1].append(l) print(d[1][0][1]) d[1][0][1]=60 print(d[1][0][1]) if __name__=='__main__': manager=mp.Manager() dic=manager.dict() dic[1]=manager.list() print(dic[1]) pr1=mp.Process(target=modif1,args=[dic]) pr1.start() pr1.join() print(dic[1])
Le problème est que la valeur de d[1][0][1] ne change pas ni chez le processus fils ni chez le processus père.

Sauriez-vous comment faire pour que la maj prenne effet ?

Merci

:salut:

Voici mon code de test, je découvre le sujet multiprocess :

Code:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
#! python3
# coding: utf-8
 
from multiprocessing import Process, Manager
import os
 
 
def info(title):
    print(title)
    print('module name:', __name__)
    print('parent process:', os.getppid())
    print('process id:', os.getpid())
 
 
def modif1(d):
    info('function modif1')
    l = [3, 4]
    d['liste'].append(l)
 
 
if __name__ == '__main__':
    info('main line')
 
    manager = Manager()
    dic = manager.dict()
    lst = manager.list()
 
    dic['liste'] = lst
 
    print("dic = ", dic)
 
    print("dic['liste'] = ", dic['liste'])
 
    p1 = Process(target=modif1, args=(dic, ))
    p1.start()
    p1.join()
 
    print("dic['liste'] = ", dic['liste'])
 
"""
PS F:\test-python> & C:/Users/User/AppData/Local/Programs/Python/Python37-32/python.exe f:/test-python/Tests/forum_dvp/a_test.py
main line
module name: __main__
parent process: 3008
process id: 1688
dic =  {'liste': <ListProxy object, typeid 'list' at 0x2a6c150>}
dic['liste'] =  []
function modif1
module name: __mp_main__
parent process: 1688
process id: 1480
dic['liste'] =  [[3, 4]]
"""

25/12/2019, 11h51
souchi

Merci pour votre reponse,

En fait j'ai besoin d'une structure de donnees du genre:
dic[1]=[[],[],.....]
dic[2]=[[],[],.....]
dic[3]=[[],[],.....]
alors le dictionnaire est crée par le processus pere et rempli par le processus fils. donc les listes a l'interieur de dic[1],dic[2] et dic[3] sont crées et ajoutées par le fils.
Le probleme est que si la liste est crée par le pere en utilisant le manager elle est partagée, mais si elle est créea par le fils, elle n'est pas partagée et ce que je ne comprend pas le plus c'est que les modifications ne sont pas effectives meme a l'interieur du code executé par le fils.

Quelqu'un pourrait nous l'expliquer?

Merci encore.
25/12/2019, 17h54
wiztricks

Salut et joyeux noël,

Citation:

Envoyé par souchi

Quelqu'un pourrait nous l'expliquer?

C'est documenté clairement:

Citation:

Si des objets standards (non proxyfiés) list ou dict sont contenus dans un référent, les modifications sur ces valeurs mutables ne seront pas propagées à travers le gestionnaire parce que le mandataire n'a aucun moyen de savoir quand les valeurs contenues sont modifiées.

et... la suite indique comment y pallier.

- W
25/12/2019, 19h49
souchi

Merci bcp!