eamelink · January 27, 2017 14:44 · Jan 27, 2017 · Jan 27, 2017
diff --git a/blocking.scala b/blocking.scala
@@ -7,13 +7,14 @@ object Test extends App {
 
   val x = Future.traverse(1 to 30){ i =>
     Future {
-      println("Starting " + i)
-        blocking {
-          Thread.sleep(2000)
-        }
+      println("Starting #" + i)
+      blocking {
+        Thread.sleep(2000)
+      }
+      println("Done with #" + i)
       i
     }
   }
 
-  println(Await.result(x, 1 minute))
+  Await.ready(x, 1 minute)
 }
diff --git a/blocking.scala b/blocking.scala
@@ -0,0 +1,19 @@
+import scala.concurrent._
+import scala.concurrent.duration._
+import scala.concurrent.ExecutionContext.Implicits.global
+
+// Experiment with and without the `blocking` call in this program!
+object Test extends App {
+
+  val x = Future.traverse(1 to 30){ i =>
+    Future {
+      println("Starting " + i)
+        blocking {
+          Thread.sleep(2000)
+        }
+      i
+    }
+  }
+
+  println(Await.result(x, 1 minute))
+}