[pyar] Heredando del Queue multiprocessing

Claudio Freire klaussfreire en gmail.com
Lun Mayo 2 05:03:54 ART 2011


2011/5/1 Facundo Batista <facundobatista en gmail.com>:
>> Queue = multiprocessing.queues.Queue
>
> No. Es raro, ¿no?
>
> Muchas gracias!

Capaz que mas acorde del disenio de Queue seria que inyectes tus
versiones decoradas:

from multiprocessing import Queue

def DeferredQueue(*p, **kw):
   q = Queue(*p, **kw)
   q.deferred_get = lambda *p, **kw : deferred(... q.get(*p, **kw) )
   ...

Es mas feo, lo concedo, pero no salteas el mecanismo de construccion
de Queues de multiprocessing.



More information about the pyar mailing list