Scala是否提供开箱即用的有界并发阻塞优先级队列实现？

嘿，刚好碰到过类似的需求！先直接给你个明确结论：Scala标准库本身并没有开箱即用的、同时满足有界特性+线程安全阻塞+优先级排序的队列实现，不过不用自己从头造轮子，有几个现成的方案可以选：

1. 用Guava的BoundedPriorityBlockingQueue（最省心） #

很多Scala项目都会依赖Guava，它里面的BoundedPriorityBlockingQueue完全符合你的需求——有界、支持优先级、线程安全且是阻塞队列。用法超简单：

import com.google.common.util.concurrent.BoundedPriorityBlockingQueue

// 初始化容量为10的队列，按元素自然顺序排序
val queue = new BoundedPriorityBlockingQueue[String](10)

// 队列满时会阻塞等待的入队操作
queue.put("低优先级任务")
queue.put("高优先级任务") // 会排在队列前面

// 队列空时会阻塞等待的出队操作
val nextTask = queue.take()

这个类内部已经帮你处理好了并发控制和边界限制，完全不用自己手动折腾Semaphore。

2. 轻量封装Java原生类（无额外依赖） #

如果不想引入Guava，其实可以用Java的PriorityBlockingQueue搭配Semaphore做个极简封装，比完全手动实现靠谱多了，代码量也很小：

import java.util.concurrent.{PriorityBlockingQueue, Semaphore}

class BoundedPriorityQueue[T](capacity: Int) {
  private val innerQueue = new PriorityBlockingQueue[T]()
  // 用信号量控制队列最大容量，公平模式保证等待线程的顺序
  private val capacitySemaphore = new Semaphore(capacity, fair = true)

  // 阻塞式入队，队列满时等待
  def put(element: T): Unit = {
    capacitySemaphore.acquire()
    try {
      innerQueue.put(element)
    } catch {
      case e: InterruptedException =>
        // 中断时释放信号量，避免资源泄漏
        capacitySemaphore.release()
        Thread.currentThread().interrupt()
        throw e
    }
  }

  // 阻塞式出队，队列空时等待
  def take(): T = {
    val element = innerQueue.take()
    capacitySemaphore.release()
    element
  }

  // 可选：非阻塞的入队尝试
  def offer(element: T): Boolean = {
    if (capacitySemaphore.tryAcquire()) {
      innerQueue.offer(element)
      true
    } else {
      false
    }
  }
}

这个封装复用了Java原生队列的优先级排序和并发安全特性，只用Semaphore做容量控制，代码简洁还不容易出错。

3. Akka生态的PriorityQueueSink（如果用Akka） #

如果你的项目已经在使用Akka，Akka Streams里的PriorityQueueSink可以配置有界容量，支持优先级排序，而且是线程安全的。不过它更适合流处理场景，如果只是需要传统的队列交互，前面两个方案更直接。

总结下来：能加Guava依赖的话，直接用BoundedPriorityBlockingQueue最省心；不想加依赖的话，上面的轻量封装也能快速解决问题，完全不算重复造轮子~

内容的提问来源于stack exchange，提问作者Some Name