Coroutine guide: more on cancellation and "Composing suspending functions" section

elizarov · elizarov · commit 1293ccdb5290 · 2017-02-02T09:17:24.000+03:00
diff --git a/coroutines-guide.md b/coroutines-guide.md
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-11.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-11.kt
@@ -1,4 +1,4 @@
-package examples
+package example11
 
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.delay
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-12.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-12.kt
@@ -1,4 +1,4 @@
-package examples
+package example12
 
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.delay
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-13.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-13.kt
@@ -1,4 +1,4 @@
-package examples
+package example13
 
 import kotlinx.coroutines.experimental.*
 
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-14.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-14.kt
@@ -1,4 +1,4 @@
-package examples
+package example14
 
 import kotlinx.coroutines.experimental.*
 
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-15.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-15.kt
@@ -1,4 +1,4 @@
-package examples
+package example15
 
 import kotlinx.coroutines.experimental.*
 
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-16.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-16.kt
@@ -1,4 +1,4 @@
-package examples
+package example16
 
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.delay
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-21.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-21.kt
@@ -1,4 +1,4 @@
-package examples
+package example21
 
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.delay
@@ -13,8 +13,8 @@ fun main(args: Array<String>) = runBlocking<Unit> {
         }
     }
     delay(1300L) // delay a bit
-    println("I'm tired of waiting!")
+    println("main: I'm tired of waiting!")
     job.cancel() // cancels the job
     delay(1300L) // delay a bit to ensure it was cancelled indeed
-    println("Now I can quit.")
+    println("main: Now I can quit.")
 }
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-22.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-22.kt
@@ -1,4 +1,4 @@
-package examples
+package example22
 
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.delay
@@ -18,8 +18,8 @@ fun main(args: Array<String>) = runBlocking<Unit> {
         }
     }
     delay(1300L) // delay a bit
-    println("I'm tired of waiting!")
+    println("main: I'm tired of waiting!")
     job.cancel() // cancels the job
     delay(1300L) // delay a bit to see if it was cancelled....
-    println("Now I can quit.")
+    println("main: Now I can quit.")
 }
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-23.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-23.kt
@@ -1,4 +1,4 @@
-package examples
+package example23
 
 import kotlinx.coroutines.experimental.CommonPool
 import kotlinx.coroutines.experimental.delay
@@ -18,8 +18,8 @@ fun main(args: Array<String>) = runBlocking<Unit> {
         }
     }
     delay(1300L) // delay a bit
-    println("I'm tired of waiting!")
+    println("main: I'm tired of waiting!")
     job.cancel() // cancels the job
     delay(1300L) // delay a bit to see if it was cancelled....
-    println("Now I can quit.")
+    println("main: Now I can quit.")
 }
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-24.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-24.kt
@@ -0,0 +1,24 @@
+package example24
+
+import kotlinx.coroutines.experimental.CommonPool
+import kotlinx.coroutines.experimental.delay
+import kotlinx.coroutines.experimental.launch
+import kotlinx.coroutines.experimental.runBlocking
+
+fun main(args: Array<String>) = runBlocking<Unit> {
+    val job = launch(CommonPool) {
+        try {
+            repeat(1000) { i ->
+                println("I'm sleeping $i ...")
+                delay(500L)
+            }
+        } finally {
+            println("I'm running finally")
+        }
+    }
+    delay(1300L) // delay a bit
+    println("main: I'm tired of waiting!")
+    job.cancel() // cancels the job
+    delay(1300L) // delay a bit to ensure it was cancelled indeed
+    println("main: Now I can quit.")
+}
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-25.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-25.kt
@@ -0,0 +1,25 @@
+package example25
+
+import kotlinx.coroutines.experimental.*
+
+fun main(args: Array<String>) = runBlocking<Unit> {
+    val job = launch(CommonPool) {
+        try {
+            repeat(1000) { i ->
+                println("I'm sleeping $i ...")
+                delay(500L)
+            }
+        } finally {
+            run(NonCancellable) {
+                println("I'm running finally")
+                delay(1000L)
+                println("And I've just delayed for 1 sec because I'm non-cancellable")
+            }
+        }
+    }
+    delay(1300L) // delay a bit
+    println("main: I'm tired of waiting!")
+    job.cancel() // cancels the job
+    delay(1300L) // delay a bit to ensure it was cancelled indeed
+    println("main: Now I can quit.")
+}
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-26.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-26.kt
@@ -0,0 +1,14 @@
+package example26
+
+import kotlinx.coroutines.experimental.delay
+import kotlinx.coroutines.experimental.runBlocking
+import kotlinx.coroutines.experimental.withTimeout
+
+fun main(args: Array<String>) = runBlocking<Unit> {
+    withTimeout(1300L) {
+        repeat(1000) { i ->
+            println("I'm sleeping $i ...")
+            delay(500L)
+        }
+    }
+}
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-31.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-31.kt
@@ -0,0 +1,24 @@
+package example31
+
+import kotlinx.coroutines.experimental.delay
+import kotlinx.coroutines.experimental.runBlocking
+import kotlin.system.measureTimeMillis
+
+suspend fun doSomethingUsefulOne(): Int {
+    delay(1000L) // pretend we are doing something useful here
+    return 13
+}
+
+suspend fun doSomethingUsefulTwo(): Int {
+    delay(1000L) // pretend we are doing something useful here, too
+    return 29
+}
+
+fun main(args: Array<String>) = runBlocking<Unit> {
+    val time = measureTimeMillis {
+        val one = doSomethingUsefulOne()
+        val two = doSomethingUsefulTwo()
+        println("The answer is ${one + two}")
+    }
+    println("Completed in $time ms")
+}
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-32.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-32.kt
@@ -0,0 +1,26 @@
+package example32
+
+import kotlinx.coroutines.experimental.CommonPool
+import kotlinx.coroutines.experimental.defer
+import kotlinx.coroutines.experimental.delay
+import kotlinx.coroutines.experimental.runBlocking
+import kotlin.system.measureTimeMillis
+
+suspend fun doSomethingUsefulOne(): Int {
+    delay(1000L) // pretend we are doing something useful here
+    return 13
+}
+
+suspend fun doSomethingUsefulTwo(): Int {
+    delay(1000L) // pretend we are doing something useful here, too
+    return 29
+}
+
+fun main(args: Array<String>) = runBlocking<Unit> {
+    val time = measureTimeMillis {
+        val one = defer(CommonPool) { doSomethingUsefulOne() }
+        val two = defer(CommonPool) { doSomethingUsefulTwo() }
+        println("The answer is ${one.await() + two.await()}")
+    }
+    println("Completed in $time ms")
+}
diff --git a/kotlinx-coroutines-core/src/test/kotlin/examples/example-33.kt b/kotlinx-coroutines-core/src/test/kotlin/examples/example-33.kt
@@ -0,0 +1,26 @@
+package example33
+
+import kotlinx.coroutines.experimental.CommonPool
+import kotlinx.coroutines.experimental.delay
+import kotlinx.coroutines.experimental.lazyDefer
+import kotlinx.coroutines.experimental.runBlocking
+import kotlin.system.measureTimeMillis
+
+suspend fun doSomethingUsefulOne(): Int {
+    delay(1000L) // pretend we are doing something useful here
+    return 13
+}
+
+suspend fun doSomethingUsefulTwo(): Int {
+    delay(1000L) // pretend we are doing something useful here, too
+    return 29
+}
+
+fun main(args: Array<String>) = runBlocking<Unit> {
+    val time = measureTimeMillis {
+        val one = lazyDefer(CommonPool) { doSomethingUsefulOne() }
+        val two = lazyDefer(CommonPool) { doSomethingUsefulTwo() }
+        println("The answer is ${one.await() + two.await()}")
+    }
+    println("Completed in $time ms")
+}

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example11`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.CommonPool`
`4`	`4`	`import kotlinx.coroutines.experimental.delay`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example12`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.CommonPool`
`4`	`4`	`import kotlinx.coroutines.experimental.delay`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example13`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.*`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example14`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.*`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example15`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.*`
`4`	`4`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example16`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.CommonPool`
`4`	`4`	`import kotlinx.coroutines.experimental.delay`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example21`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.CommonPool`
`4`	`4`	`import kotlinx.coroutines.experimental.delay`
`@@ -13,8 +13,8 @@ fun main(args: Array<String>) = runBlocking<Unit> {`
`13`	`13`	`}`
`14`	`14`	`}`
`15`	`15`	`delay(1300L) // delay a bit`
`16`		`- println("I'm tired of waiting!")`
	`16`	`+ println("main: I'm tired of waiting!")`
`17`	`17`	`job.cancel() // cancels the job`
`18`	`18`	`delay(1300L) // delay a bit to ensure it was cancelled indeed`
`19`		`- println("Now I can quit.")`
	`19`	`+ println("main: Now I can quit.")`
`20`	`20`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example22`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.CommonPool`
`4`	`4`	`import kotlinx.coroutines.experimental.delay`
`@@ -18,8 +18,8 @@ fun main(args: Array<String>) = runBlocking<Unit> {`
`18`	`18`	`}`
`19`	`19`	`}`
`20`	`20`	`delay(1300L) // delay a bit`
`21`		`- println("I'm tired of waiting!")`
	`21`	`+ println("main: I'm tired of waiting!")`
`22`	`22`	`job.cancel() // cancels the job`
`23`	`23`	`delay(1300L) // delay a bit to see if it was cancelled....`
`24`		`- println("Now I can quit.")`
	`24`	`+ println("main: Now I can quit.")`
`25`	`25`	`}`
Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,4 @@`
`1`		`-package examples`
	`1`	`+package example23`
`2`	`2`
`3`	`3`	`import kotlinx.coroutines.experimental.CommonPool`
`4`	`4`	`import kotlinx.coroutines.experimental.delay`
`@@ -18,8 +18,8 @@ fun main(args: Array<String>) = runBlocking<Unit> {`
`18`	`18`	`}`
`19`	`19`	`}`
`20`	`20`	`delay(1300L) // delay a bit`
`21`		`- println("I'm tired of waiting!")`
	`21`	`+ println("main: I'm tired of waiting!")`
`22`	`22`	`job.cancel() // cancels the job`
`23`	`23`	`delay(1300L) // delay a bit to see if it was cancelled....`
`24`		`- println("Now I can quit.")`
	`24`	`+ println("main: Now I can quit.")`
`25`	`25`	`}`