Use case of scala.concurrent.blocking

by
  1. The new threads are spawned in the fork/join pool when it detects
    that all the threads in the fork/join pool are waiting on each other
    using the join construct, and there is more work to be completed
    that could potentially finish one of the threads.
    Alternatively, if one of the ForkJoinWorker threads is executing code that blocks other than by using join, it can notify the pool using ManagedBlockers.
  2. It is potentially applicable to any kind of execution contexts — it serves as a notification to the ExecutionContext implementation that the code executed by a worker thread is potentially blocking on some condition, and that this condition might be resolved by computing something else using some other thread. The execution context may or may not act on this. In the current (2.10, 2.11) implementation, blocking will work only with the default global execution context.
  3. If you wrap any executable with blocking you will induce a bit of runtime overhead, so don’t always do it.
  4. If you have a computation that lasts a long time, e.g. seconds or minutes, or you are waiting on a future to complete using Await, or you are waiting on a monitor’s condition to become resolved, and this condition can be resolved by some other task/future that should execute on the same execution context — in all these cases you should use blocking.

EDIT:

Consider taking a look at Chapter 4 in the Learning Concurrent Programming in Scala book.

More Related Contents:

  1. What is a TypeTag and how do I use it?
  2. Scala’s “postfix ops”
  3. Generating a class from string and instantiating it in Scala 2.10
  4. Finding type parameters via reflection in Scala 2.10?
  5. What’s the easiest way to use reify (get an AST of) an expression in Scala?
  6. How do I access default parameter values via Scala reflection?
  7. How to get ClassTag form TypeTag, or both at same time?
  8. Static return type of Scala macros
  9. Creating a method definition tree from a method symbol and a body
  10. Scala generic method – No ClassTag available for T
  11. Scala 2.10 reflection, how do I extract the field values from a case class, i.e. field list from case class
  12. How to know if an object is an instance of a TypeTag’s type?
  13. What is the purpose of type ascriptions in Scala?
  14. Provide schema while reading csv file as a dataframe
  15. How to flatmap a nested Dataframe in Spark
  16. Scala return statements in anonymous functions
  17. Is there a reason not to use SparkContext.getOrCreate when writing a spark job?
  18. What are the various join types in Spark?
  19. What is the rule for parenthesis in Scala method invocation?
  20. How to calculate the size of dataframe in bytes in Spark?
  21. Why does partition parameter of SparkContext.textFile not take effect?
  22. Can I zip more than two lists together in Scala?
  23. Cross product in Scala
  24. Spark Scala list folders in directory
  25. Exception in thread “main” java.lang.NoSuchMethodError: scala.Product.$init$(Lscala/Product;)
  26. How to remove parentheses around records when saveAsTextFile on RDD[(String, Int)]?
  27. Reading in multiple files compressed in tar.gz archive into Spark [duplicate]
  28. ScalaTest in sbt: is there a way to run a single test without tags?
  29. Missing parameter type error by calling toSet?
  30. How to vectorize DataFrame columns for ML algorithms?

Leave a Comment