マルチプロセッシングキューのサブクラスの問題

Question

キューのチャンクを取得するプロセスを実装するために、マルチプロセッシングをサブクラス化したい。唯一の問題は、奇妙なTypeErrorが発生していることです。

この（私は他の何かに引っ張っていなかったように私はこれを分割）

| => ./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 

編集/更新テスト

#!/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)] 

：

Answer 1

multiprocessing.Queueは、キューを作成する方法であるので、あなたをそれを関数として使用するはずですmy_queue = Queue()。

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

ご覧のとおり、サブクラス化に使用する「タイプ」はありません。

あなたがあなた自身のキューを実装したい場合は、見てみることができqueue.Queue

EDIT：

あなたはタイプがある、代わりにmultiprocessing.queues.Queueを、マルチプロセッシングからキューをサブクラス使用したい場合multiprocessing.Queue()