Python PriorityQueue 加入到特定优先级

问：

我正在尝试实现一个带有连接函数的 PriorityQueue，该函数会阻塞，直到队列中达到指定优先级的所有项目都被获取和处理。不幸的是，我被卡住了，因为我认为在向队列添加项目时需要提前指定该优先级截止值。

我正在尝试实现具有以下签名的函数：

def join_until_priority(self, priority):

但是从Python的实现来看，该函数似乎是基于等待计数器达到。queue.Queuejoin()unfinished_tasks0

我认为这意味着我必须在“插入时间”而不是“加入时间”时知道所需的优先级截止值，以便我可以创建例如的计数器。unfinished_priority_1000_tasks

这对我来说似乎是一个相当常见的任务，所以我很惊讶默认情况下不支持它。还是我缺少一种更简单的方法？