How to cancel Future in Scala?

by

This is not yet a part of the Futures API, but may be added as an extension in the future.

As a workaround, you could use the firstCompletedOf to wrap 2 futures – the future you want to cancel and a future that comes from a custom Promise. You could then cancel the thus created future by failing the promise:

def cancellable[T](f: Future[T])(customCode: => Unit): (() => Unit, Future[T]) = {
  val p = Promise[T]
  val first = Future firstCompletedOf Seq(p.future, f)
  val cancellation: () => Unit = {
    () =>
      first onFailure { case e => customCode}
      p failure new Exception
  }
  (cancellation, first)
}

Now you can call this on any future to obtain a “cancellable wrapper”. Example use-case:

val f = callReturningAFuture()
val (cancel, f1) = cancellable(f) {
  cancelTheCallReturningAFuture()
}

// somewhere else in code
if (condition) cancel() else println(Await.result(f1))

EDIT:

For a detailed discussion on cancellation, see Chapter 4 in the Learning concurrent programming in Scala book.

More Related Contents:

  1. How to configure a fine tuned thread pool for futures?
  2. Asynchronous IO in Scala with futures
  3. How should I unit test multithreaded code?
  4. Difference between -pthread and -lpthread while compiling
  5. JavaFX2: Can I pause a background Task / Service?
  6. Does lock xchg have the same behavior as mfence?
  7. what is the correct way to implement a QThread… (example please…)
  8. CoreData: warning: Unable to load class named
  9. Can Selenium use multi threading in one browser?
  10. Is NodeJS really Single-Threaded?
  11. What is thread contention?
  12. How to make Qt work when main thread is busy?
  13. Does an x86 CPU reorder instructions?
  14. What is a “thread” (really)?
  15. Difference between the TPL & async/await (Thread handling)
  16. Doxygen is Slow
  17. Running two threads at the same time
  18. How, if at all, do Erlang Processes map to Kernel Threads?
  19. Multithreading: What is the point of more threads than cores?
  20. How to detect and debug multi-threading problems?
  21. Thread references require static lifetime?
  22. Does multithreading make sense for IO-bound operations?
  23. “Collection was mutated while being enumerated” on executeFetchRequest
  24. Spring @Async limit number of threads
  25. Does an asynchronous call always create/call a new thread?
  26. Is it better to use TThread’s “Synchronize” or use Window Messages for IPC between main and child thread?
  27. What happens when different CPU cores write to the same RAM address without synchronization?
  28. Does multi-threading improve performance? How?
  29. Futures do not run before program termination
  30. Thread-safe in delphi

Leave a Comment