Utilisation de jeux avec le module multitraitement

Question

Je n'arrive pas à partager un ensemble de processus à l'aide d'une instance Manager. Une version condensée de mon code:

from multiprocessing.managers import SyncManager 
manager = SyncManager() 
manager.start() 
manager.register(Set) 

J'ai aussi essayé register(type(Set)) et register(Set()), mais je ne suis pas trop surpris de constater que ni d'entre eux travaillaient (la première devrait évaluer la classe, je pense).

L'exception que je reçois dans tous les cas est TypeError: __name__ must be set to a string object dans la ligne 675 de managers.py.

Existe-t-il un moyen de le faire, ou ai-je besoin d'étudier des alternatives?

Answer 1

Le premier argument de la SyncManager.register() class method doit être une chaîne , pas cass:

SyncManager.register('set', set) 

mais vous devez vous inscrire un proxy pour les jeux ainsi:

from multiprocessing.managers import MakeProxyType 

BaseSetProxy = MakeProxyType('BaseSetProxy', (
    '__and__', '__contains__', '__iand__', '__ior__', 
    '__isub__', '__ixor__', '__len__', '__or__', '__rand__', '__ror__', '__rsub__', 
    '__rxor__', '__sub__', '__xor__', 'add', 'clear', 'copy', 'difference', 
    'difference_update', 'discard', 'intersection', 'intersection_update', 'isdisjoint', 
    'issubset', 'issuperset', 'pop', 'remove', 'symmetric_difference', 
    'symmetric_difference_update', 'union', 'update'] 
    )) 
class SetProxy(BaseSetProxy): 
    # in-place hooks need to return `self`, specify these manually 
    def __iand__(self, value): 
     self._callmethod('__iand__', (value,)) 
     return self 
    def __ior__(self, value): 
     self._callmethod('__ior__', (value,)) 
     return self 
    def __isub__(self, value): 
     self._callmethod('__isub__', (value,)) 
     return self 
    def __ixor__(self, value): 
     self._callmethod('__ixor__', (value,)) 
     return self 

SyncManager.register('set', set, SetProxy)