Scala 封装可break和continue的foreach循环

Posted DrWong

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Scala 封装可break和continue的foreach循环相关的知识,希望对你有一定的参考价值。

发现scala里没有break和continue, 有时候实在是需要的话就要自己try catch异常,代码看起来有点蛋疼, 所以封装了一个可break和continue的foreach.

import scala.collection.TraversableLike

case class Breakable() {

  def break: Unit = throw new BreakException

  def continue: Unit = throw new ContinueException

  def foreach(t: TraversableLike[_, _], op: Any => Unit): Unit = {
    try {
      t.foreach(i => {
        try {
          op(i)
        }catch {
          case ex : Throwable =>
            if(!ex.isInstanceOf[ContinueException]) throw ex
        }
      })
    }catch {
      case ex : Throwable =>
        if(!ex.isInstanceOf[BreakException]) throw ex
    }
  }
  class BreakException extends Exception
  class ContinueException extends Exception
}

  

 

 

使用

 

import com.myTest.util.Breakable

/**
 * Created by Administrator on 2017/2/25 0025.
 */
object TestCode {
  def main(args: Array[String]) {
    val b = Breakable()
    val a = List(1,2,3,4,5,6,7,8,9)
    b.foreach(a, i => {
      if(i == 5) b.continue
      if(i == 7) b.break
      println(i)
    })
  }

}

  输出

 

1
2
3
4
6

 

以上是关于Scala 封装可break和continue的foreach循环的主要内容,如果未能解决你的问题,请参考以下文章

Scala语言基础之结合demo和spark讲实现链式计算

Scala的ClassObjectTrait

Scala实战高手****第7课:零基础实战Scala面向对象编程及Spark源码解析

通过python扩展spark mllib 算法包(e.g.基于spark使用孤立森林进行异常检测)

使用 Spark 和 Scala 过滤掉任何无法正确解析的记录

Scala基础