自定义迭代队列IterQueue报错'IterQueue' object has no attribute 'not_full'的解决方案求助

嘿，我来帮你捋捋这个问题！

你碰到的这个'IterQueue' object has no attribute 'not_full'错误，核心原因其实很简单：你重写了IterQueue的__init__方法，但完全没调用父类queue.Queue的初始化逻辑。queue.Queue内部靠not_full这个Condition对象来实现线程安全的队列操作（比如你用到的put方法就依赖它），你的子类没初始化这些父类的核心属性，调用put时自然就会报错。

下面给你具体的修复方案和优化建议：

第一步：修复初始化问题 #

先把父类的初始化方法加上，确保队列的核心同步属性被正确创建：

from multiprocessing import Process, Queue, Pool
import queue

class IterQueue(queue.Queue):

    def __init__(self):
        # 必须先调用父类的__init__，初始化not_full、not_empty等核心同步对象
        super().__init__()
        self.current = 0
        self.end = 10000

    def __iter__(self):
        # 调整迭代逻辑：迭代队列中的元素，直到队列为空（避免无限阻塞）
        try:
            while True:
                # 设置短超时，避免一直等待新元素（可根据需求调整超时时间）
                item = self.get(block=True, timeout=0.1)
                yield item
        except queue.Empty:
            # 队列为空时终止迭代
            return

    # 原__next__方法实现的是独立计数器逻辑，和队列元素无关，若不需要可直接删除
    # 如果你确实需要保留计数器功能，建议和队列迭代逻辑分开，避免混淆

额外说明 #

1. 关于多进程队列的注意点：如果你是在多进程环境下使用这个队列，其实queue.Queue是线程间通信用的，进程间通信更适合用multiprocessing.Queue。不过不管继承哪个队列类，都必须调用父类的__init__来初始化内部属性，否则都会出现类似的属性缺失问题。
2. 迭代逻辑的优化：你原来的__iter__是无限yield self.get()，会一直阻塞等待新元素，永远不会主动停止。上面的代码改成了捕获queue.Empty异常，当队列为空超过设定的超时时间后就终止迭代，更符合常规的迭代器使用预期。

备注：内容来源于stack exchange，提问作者Mohammed Baashar