मल्टीप्रोसेसिंग क्यूई सबक्लास समस्या

Question

मैं मल्टीप्रोसेसिंग को उपclass करना चाहता हूं। कतार के हिस्सों को पकड़ने के लिए प्रक्रियाओं को कार्यान्वित करने के लिए क्यूयू। एकमात्र समस्या यह है कि, मुझे एक अजीब टाइपरर मिल रहा है?

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

संपादित करें/अद्यतन:

Answer 1

multiprocessing.Queue एक विधि है कि कतारों बनाता है, तो आप इसे एक फ़ंक्शन my_queue = Queue() के रूप में उपयोग करने के लिए माना जाता है।

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

जैसा कि आप देख सकते हैं एक 'प्रकार' नहीं है, जिसे आप उपclass के लिए उपयोग करेंगे।

आप अपने खुद के कतार लागू करना चाहते हैं, तो आप पर एक नज़र ले सकता है queue.Queue

संपादित करें:

आप बहु से कतार, बजाय उपवर्ग का उपयोग multiprocessing.queues.Queue, जो प्रकार है चाहते हैं multiprocessing.Queue()