многопроцессорный вызов подкласса очереди

Question

Я хочу подмножество многопроцессорности.Queue для реализации процессов для захвата кусков очереди. Единственная проблема: я получаю странный 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)] 

тестирование этого (я разделил это так, что я не тянул ни в чем друг)

| => ./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 является методом, который создает очередь, так что вы Предполагается использовать его как функцию my_queue = Queue().

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

Как вы можете видеть, это не «тип», который вы использовали бы в подклассе.

Если вы хотите реализовать свою собственную очередь, вы могли бы взглянуть на queue.Queue

EDIT:

Если вы хотите, чтобы подклассы очередь из многопроцессорной, используйте multiprocessing.queues.Queue вместо этого, что тип от объекта, возвращаемого multiprocessing.Queue()