Problema di sottoclasse della coda di multiprocessing

Question

Voglio sottoclasse multiprocessing.Queue per l'implementazione dei processi per l'acquisizione di blocchi della coda. L'unico problema è che sto ottenendo uno strano errore TypeError?

#!/usr/bin/env python 

#whaaaaa!? 

from multiprocessing import Queue 

class BufferQueue(Queue): 
    '''A thread/process safe queue for append/popleft operations with the import 
    buffer.''' 

    def __init__(self, **kwargs): 
     super(BufferQueue,self).__init__(**kwargs) 

    def consume(self, lim): 
     '''Consume up to but no more than lim elements and return them in a new 
     list, cleaning up the buffer. 

     @params 
     lim -- the maximum (limit) to consume from the list. If less items 
     exist in the list then that's fine too. 
     ''' 
     lim = len(queue) if len(queue) < lim else lim 
     return [self.popleft() for i in range(lim)] 

prove (ho diviso questo in modo che io non stavo tirando in qualsiasi altra cosa)

| => ./tests/wtf_queue.py 
Traceback (most recent call last): 
    File "./tests/wtf_queue.py", line 10, in <module> 
    class BufferQueue(Queue): 
TypeError: method expected 2 arguments, got 3 

Edit/Update:

Answer 1

multiprocessing.Queue è un metodo che crea code, in modo da Dovresti usarlo come una funzione my_queue = Queue().

>>> from multiprocessing import Queue 
>>> type(Queue) 
<class 'method'> 

Come puoi vedere non è un 'tipo', che useresti per sottoclasse.

Se si desidera implementare la propria coda, si può dare un'occhiata a queue.Queue

EDIT:

Se si desidera creare una sottoclasse della coda da multiprocessing, utilizzare multiprocessing.queues.Queue invece, che è il tipo di dell'oggetto restituito da multiprocessing.Queue()