multiprocessing Queue subclass issue

Question

Tôi muốn phân lớp multiprocessing.Queue để thực hiện các quy trình lấy khối của hàng đợi. Vấn đề duy nhất là, tôi nhận được một TypeError lạ?

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

thử nghiệm này (tôi chia này ra vì vậy mà tôi đã không kéo trong bất cứ điều gì khác)

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

Chỉnh sửa/Cập nhật:

Answer 1

multiprocessing.Queue là một phương pháp tạo ra hàng đợi, vì vậy bạn được cho là sử dụng nó như một hàm my_queue = Queue().

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

Như bạn có thể thấy không phải là 'loại', mà bạn sẽ sử dụng cho phân lớp.

Nếu bạn muốn thực hiện hàng đợi riêng bạn, bạn có thể có một cái nhìn tại queue.Queue

EDIT:

Nếu bạn muốn phân lớp hàng đợi từ đa, sử dụng multiprocessing.queues.Queue thay vào đó, đó là loại đối tượng được trả về bởi multiprocessing.Queue()