Schedules a task to be run continuously without using Akka system or other schedulers

ScheduleContinuously.scala

import scala.concurrent._
import ExecutionContext.Implicits.global

object Main extends App {

    def repeatEvery[T](timeoutMillis: Int)(f: => T): Future[T] = {
      val p = Promise[T]()
      val never = p.future
      f
      def timeout = Future {
        Thread.sleep(timeoutMillis)
        throw new TimeoutException
      }
      val failure = Future.firstCompletedOf(List(never, timeout))
      failure.recoverWith { case _ => repeatEvery(timeoutMillis)(f) }
    }

    repeatEvery(1000) {
      println("scheduled job called")
    }

    println("main started doing its work")
    Thread.sleep(10000)
    println("main finished")
}

Prints:

scheduled job called
main started doing its work
scheduled job called
scheduled job called
scheduled job called
scheduled job called
scheduled job called
scheduled job called
scheduled job called
scheduled job called
scheduled job called
main finished