Scala ArrayDeque类代码示例

OStack程序员社区-中国程序员成长平台 › 门户 › 编程› Scala›Scala教程

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Scala中java.util.ArrayDeque类的典型用法代码示例。如果您正苦于以下问题：Scala ArrayDeque类的具体用法？Scala ArrayDeque怎么用？Scala ArrayDeque使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

在下文中一共展示了ArrayDeque类的1个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Scala代码示例。

示例1: NonShrinkingCluster

//设置package包名称以及导入依赖的类
package com.twitter.finagle.builder

import com.twitter.concurrent.Spool
import com.twitter.concurrent.SpoolSource
import com.twitter.util.Future
import java.util.ArrayDeque


class NonShrinkingCluster[T](underlying: Cluster[T]) extends Cluster[T] {
  import Cluster._

  def snap: (Seq[T], Future[Spool[Change[T]]]) = {
    val outgoing = new SpoolSource[Change[T]]
    val queue = new ArrayDeque[T]

    val (init, changes) = underlying.snap

    for (spool <- changes; change <- spool) queue.synchronized {
      change match {
        case Add(node) if queue.contains(node) =>
          queue.remove(node)
        case Add(node) =>
          Option(queue.poll()) foreach { c => outgoing.offer(Rem(c)) }
          outgoing.offer(change)
        case Rem(node) =>
          queue.offer(node)
      }
    }
    (init, outgoing())
  }
}

开发者ID:deenar，项目名称:fintest，代码行数:32，代码来源:NonShrinkingCluster.scala

注：本文中的java.util.ArrayDeque类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。