Scala ultimately类代码示例

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

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

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

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

示例1: TraceableExecutionContext

//设置package包名称以及导入依赖的类
package cores.traceable.internal

import java.util.Map

import org.slf4j.MDC

import scala.concurrent.{ExecutionContext, ExecutionContextExecutor}
import scala.util.control.Exception.{Catch, ultimately}


private[internal] final class TraceableExecutionContext(mdcContext: Map[String, String], delegate: ExecutionContext) extends ExecutionContextExecutor {
  def execute(runnable: Runnable): Unit = delegate.execute(new Runnable {
    def run() {
      val oldMDCContext = MDC.getCopyOfContextMap
      setContextMap(mdcContext)
      withResetContext(oldMDCContext) {
        runnable.run()
      }
    }
  })

  private[this] def setContextMap(context: Map[String, String]) {
    Option(context) match {
      case Some(c) => MDC.setContextMap(c)
      case None => MDC.clear()
    }
  }

  private def withResetContext(context: Map[String, String]): Catch[Unit] = {
    ultimately[Unit] {
      setContextMap(context)
    }
  }

  def reportFailure(t: Throwable): Unit = delegate.reportFailure(t)
}

开发者ID:tmknom，项目名称:scala-ddd，代码行数:37，代码来源:TraceableExecutionContext.scala

示例2: ExecutionStart

//设置package包名称以及导入依赖的类
package cores.task.internal

import cores.internal.constant.MdcKey
import cores.internal.request.RequestId
import org.slf4j.MDC
import play.api.{Application, Logger, Play}

import scala.util.control.Exception.{Catch, ultimately}
import scala.util.{Failure, Success, Try}


private[task] object ExecutionStart {
  private val startTime: Long = System.currentTimeMillis()

  def start(execution: Execution): Unit = {
    val app: Application = startApplication()
    withCleanup(app) {
      executeQuietly(execution, app)
    }
  }

  private def executeQuietly(execution: Execution, app: Application): Unit = {
    Try(execution.execute(app)) match {
      case Success(_) => Logger.info(s"${execution.getClass.getSimpleName} is success.")
      case Failure(e) => Logger.error(s"${execution.getClass.getSimpleName} is error!", e)
    }
  }

  private def startApplication(): Application = {
    MDC.put(MdcKey.RequestId, RequestId.initialize().value)
    Logger.info("Starting application.")
    ApplicationInitializer.initialize()
  }

  private def withCleanup(app: Application): Catch[Unit] = {
    ultimately[Unit] {
      Play.stop(app)
      val endTime: Float = (System.currentTimeMillis() - startTime) / 1000f
      Logger.info(s"Stopping application, total time: ${"%.1f".format(endTime)} s.")
      MDC.remove(MdcKey.RequestId)
    }
  }
}

开发者ID:tmknom，项目名称:scala-ddd，代码行数:44，代码来源:ExecutionStart.scala

示例3: load

//设置package包名称以及导入依赖的类
package cores.test.fixture

import scala.io.Source
import scala.util.control.Exception.ultimately


  def load(path: String): String = {
    val source = Source.fromInputStream(getClass.getResourceAsStream(path))
    withFinally(source: Source) {
      source.mkString
    }
  }

  private def withFinally(source: Source) = {
    ultimately {
      source.close()
    }
  }
}

开发者ID:tmknom，项目名称:scala-ddd，代码行数:20，代码来源:FixtureLoader.scala

示例4: ExecutionStartSpec

//设置package包名称以及导入依赖的类
package cores.task.internal

import cores.task.Task
import org.scalatestplus.play.PlaySpec
import play.api.{Application, Logger}

import scala.util.control.Exception.{Catch, ultimately}

class ExecutionStartSpec extends PlaySpec {
  "ExecutionStart#start" should {
    "?????????" in {
      noException mustBe thrownBy {
        ExecutionStart.start(TestTask)
      }
    }
  }

  private object TestTask extends Task {
    override def execute(app: Application): Unit = {
      Logger.trace("test")
    }

    override protected def withExit: Catch[Unit] = ultimately[Unit]{}
  }

}

开发者ID:tmknom，项目名称:scala-ddd，代码行数:27，代码来源:ExecutionStartSpec.scala

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