threadAndFuture.scala

import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{Failure, Success}

object Test extends App {
  println("1 " + Thread.currentThread().getId)
  try {
    Future {
      println("2 " + Thread.currentThread().getId)
      throw new RuntimeException()
    }.onComplete {
      case Success(x) => println("3 " + Thread.currentThread().getId)
      case Failure(e) =>
        println("4 " + Thread.currentThread().getId)
        throw e
    }
  } catch {
    case e: Exception =>
      println("cateched")
      throw e
  }
  Thread.sleep(5000)
}