加入收藏 | 设为首页 | 会员中心 | 我要投稿 李大同 (https://www.lidatong.com.cn/)- 科技、建站、经验、云计算、5G、大数据,站长网!
当前位置: 首页 > 综合聚焦 > 服务器 > 安全 > 正文

Scala中几个Seqs的懒惰笛卡尔积

发布时间:2020-12-16 09:01:35 所属栏目:安全 来源:网络整理
导读:我实现了一个简单的方法来生成笛卡儿几个Seqs产品,如下所示: object RichSeq { implicit def toRichSeq[T](s: Seq[T]) = new RichSeq[T](s)}class RichSeq[T](s: Seq[T]) { import RichSeq._ def cartesian(ss: Seq[Seq[T]]): Seq[Seq[T]] = { ss.toList ma
我实现了一个简单的方法来生成笛卡儿几个Seqs产品,如下所示:

object RichSeq {
  implicit def toRichSeq[T](s: Seq[T]) = new RichSeq[T](s)
}

class RichSeq[T](s: Seq[T]) {

  import RichSeq._

  def cartesian(ss: Seq[Seq[T]]): Seq[Seq[T]] = {

    ss.toList match {
      case Nil        => Seq(s)
      case s2 :: Nil  => {
        for (e <- s) yield s2.map(e2 => Seq(e,e2))
      }.flatten
      case s2 :: tail => {
        for (e <- s) yield s2.cartesian(tail).map(seq => e +: seq)
      }.flatten
    }
  }
}

显然,这一次真的很慢,因为它会一次计算整个产品.有没有人在Scala中实现这个问题的懒惰解决方案?

UPD

好的,所以我实现了一个笨蛋,但是在笛卡尔乘积的迭代器的工作版本.在这里发布给未来的爱好者:

object RichSeq {
  implicit def toRichSeq[T](s: Seq[T]) = new RichSeq(s) 
}

class RichSeq[T](s: Seq[T]) {

  def lazyCartesian(ss: Seq[Seq[T]]): Iterator[Seq[T]] = new Iterator[Seq[T]] {

    private[this] val seqs = s +: ss

    private[this] var indexes = Array.fill(seqs.length)(0)

    private[this] val counts = Vector(seqs.map(_.length - 1): _*)

    private[this] var current = 0

    def next(): Seq[T] = {
      val buffer = ArrayBuffer.empty[T]
      if (current != 0) {
        throw new NoSuchElementException("no more elements to traverse")
      }
      val newIndexes = ArrayBuffer.empty[Int]
      var inside = 0
      for ((index,i) <- indexes.zipWithIndex) {
        buffer.append(seqs(i)(index))
        newIndexes.append(index)
        if ((0 to i).forall(ind => newIndexes(ind) == counts(ind))) {
          inside = inside + 1
        }
      }
      current = inside
      if (current < seqs.length) {
        for (i <- (0 to current).reverse) {
          if ((0 to i).forall(ind => newIndexes(ind) == counts(ind))) {
            newIndexes(i) = 0
          } else if (newIndexes(i) < counts(i)) {
            newIndexes(i) = newIndexes(i) + 1
          }
        }
        current = 0
        indexes = newIndexes.toArray
      }
      buffer.result()
    }

    def hasNext: Boolean = current != seqs.length
  }
}

解决方法

这是我给出的问题的解决方案.请注意,懒惰只是使用.view查看用于理解的“根集”.

scala> def combine[A](xs: Traversable[Traversable[A]]): Seq[Seq[A]] =
     |  xs.foldLeft(Seq(Seq.empty[A])){
     |    (x,y) => for (a <- x.view; b <- y) yield a :+ b }
combine: [A](xs: Traversable[Traversable[A]])Seq[Seq[A]]
scala> combine(Set(Set("a","b","c"),Set("1","2"),Set("S","T"))) foreach (println(_))
List(a,1,S)
List(a,T)
List(a,2,T)
List(b,S)
List(b,T)
List(c,S)
List(c,T)

为了获得这个,我从https://stackoverflow.com/a/4515071/53974中定义的函数组合开始,传递函数(a,b)=> (a,b).然而,这并不直接起作用,因为该代码期望类型(A,A)=>所以我只是修改了代码.

(编辑:李大同)

【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容!

    推荐文章
      热点阅读