Ajouter des objets à une liste multiprocessing.Manager.list()

Bonjour,

J'essaie de m'initier à la programmation multithreads, mais je me heurte à un problème pour partager une liste d'objets entre plusieurs threads.
J'ai lu dans la documentation qu'on pouvait utiliser un Manager pour contenir des objets qui pourront être manipulés par plusieurs processus.
http://docs.python.org/library/multi...ween-processes

Quand je crée une liste avec Manager.list(), et que j'y insère des entiers, tout se passe bien (comme dans l'exemple donné dans la doc).

Mais quand la liste contient des instances d'une classe que j'ai écrite, ça ne marche pas.

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12

from multiprocessing import Process, Manager   class Complex: def __init__(self, realpart, imagpart): self.r = realpart self.i = imagpart   m = Manager() l = m.list()   x = Complex(3.0, -4.5) l.append(x)

---

J'obtiens :

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12

Traceback (most recent call last): File "<stdin>", line 1, in <module> File "<string>", line 2, in append File "/usr/lib/python2.6/multiprocessing/managers.py", line 740, in _callmethod raise convert_to_error(kind, result) multiprocessing.managers.RemoteError: --------------------------------------------------------------------------- Traceback (most recent call last): File "/usr/lib/python2.6/multiprocessing/managers.py", line 214, in serve_client request = recv() AttributeError: 'module' object has no attribute 'Complex' ---------------------------------------------------------------------------

---

Je ne comprends pas cette erreur, et vous ?
Est-ce que cela veut dire qu'on ne peut pas utiliser d'objets dans une liste gérée par un multiprocessing.Manager ?
Une telle limitation m'étonnerait...

Bonjour,

tu es sur un environnement Windows ?

si oui:

http://docs.python.org/library/multi...g.html#windows

du coup:

Code:

---

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

from multiprocessing import Manager, Process   class Complex(object):   def __init__(self, realpart, imagpart):   self.r = realpart self.i = imagpart   if __name__ == "__main__":   x = Complex(3.0,-4.5) m = Manager() l = m.list() l.append(x)

---

Salut,
Je n'ai pas le temps de jouer avec en ce moment mais ta réponse à l'air de dire qu'on ne sait partager que des constantes read-only... :cry:

L'erreur dirait plutôt que recv ne sait pas ce que faire d'un Complex dans le contexte d'un Manager.
Pour autant que ce soit "possible", il faut apprendre aux Managers ce qu'est un Complex. Probablement via un "register de l'objet" et une sous classe.
Mais je n'ai pas le temps de jouer avec cette idée aujourd'hui
- W

j'ai réussi à reproduire le même problème que l'op sous Windows, en ajoutant le bloc if __name__ == "__main__", je n'ai plus l'erreur.

c'est une limitation connue du module multiprocessing avec Windows.

Problème résolu.
En fait, j'avais fait une petite erreur dans mon code de départ.

Je créais un Manager avant d'avoir défini ma classe :

Code:

---

1 2 3 4

m = Manager()   class Complex(): ...

---

au lieu de :

Code:

---

1 2 3

class Complex(): ... m = Manager()

---

J'ai échangé ces bouts de code, et ça a marché.

Merci pour vos réponses.