求Scala/Java中并发添加性能最优的集合选型建议

针对你的场景，我推荐几个完美匹配需求的并发集合，完全能解决你当前用synchronized块导致的性能问题，咱们详细说：

这绝对是你场景下的最优解，原因如下：

• 无锁CAS实现：并发插入时完全没有锁阻塞，数十万条逐条插入的吞吐量比synchronized的ListBuffer高几个数量级；单线程访问时几乎没有额外性能损耗，完全不会影响你的性能指标记录。
• 无界自动扩容：基于链表结构，不需要预先指定容量，不管数据量多大都能高效应对扩容，完全符合你“容量未知”的需求。
• 适配你的读写约束：你只在无追加操作时读取和清空，而它的读操作（遍历）本身就是无锁安全的；清空操作如果觉得原生clear()遍历效率不够，还可以用一个小技巧：用volatile变量指向当前队列，清空时直接替换成新的空队列，瞬间完成（代码示例在下面）。
• 不关心顺序完全兼容：它是FIFO队列，但你不需要关心元素顺序，所以完全不影响使用。

在Scala里你可以直接用java.util.concurrent.ConcurrentLinkedQueue，或者用Scala标准库封装的scala.collection.concurrent.Queue，API更贴合Scala习惯，比如用enqueue代替add。

优化清空操作的小技巧 #

如果你觉得原生clear()遍历节点的效率不够（毕竟是非关键操作，但能优化更好），可以这么写：

import java.util.concurrent.ConcurrentLinkedQueue
import scala.jdk.CollectionConverters._

class FastMetricsQueue[T] {
  // volatile保证多线程可见性
  @volatile private var queue = new ConcurrentLinkedQueue[T]()

  def add(item: T): Boolean = queue.add(item)

  // 清空操作O(1)，直接替换队列
  def clear(): Unit = {
    queue = new ConcurrentLinkedQueue[T]()
  }

  // 读取时转成Scala迭代器（仅在无追加时调用）
  def items: Iterable[T] = queue.asScala
}

如果你的并发场景极端高（比如数十个线程同时插入），LinkedTransferQueue是更好的选择：

• 它同样是无锁实现，在高并发下的吞吐量比ConcurrentLinkedQueue更优，内部优化了更多CAS细节。
• 同样支持无界扩容，单线程损耗极小，完全适配你的需求。
• 唯一的小缺点是API比ConcurrentLinkedQueue稍复杂，但对你的逐条插入场景来说，只用add方法就足够了。

你用synchronized包裹ListBuffer或者var buf: List，问题出在独占锁：每次只有一个线程能进入同步块，并发插入时大量线程阻塞等待，直接拉低了吞吐量；而且synchronized块本身有上下文切换的开销，哪怕单线程时也会有额外损耗，严重影响你记录的性能指标。而无锁集合用CAS原子操作，不需要阻塞，性能提升非常明显。

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