FinagleFutureTester.scala

import com.twitter.util.{ Future => TFuture, _}

object Tester extends App {
  def test1(): Unit = {
    implicit val timer: Timer = new ScheduledThreadPoolTimer()
    val startTime = System.currentTimeMillis()
    val longProcess: TFuture[String] = TFuture { Thread.sleep(1000); "done" }

    longProcess.raiseWithin(Duration.fromMilliseconds(100))
      .onSuccess { _ => val elapsed = System.currentTimeMillis() - startTime; println(s"long process Success, elapsed = $elapsed")}
      .onFailure { e: Throwable => println(s"Timedout !! e = " + e.getMessage)}
  }

  test1()
}