[//]: # (title: Coroutines basics) This section covers basic coroutine concepts. ## Your first coroutine A _coroutine_ is an instance of suspendable computation. It is conceptually similar to a thread, in the sense that it takes a block of code to run that works concurrently with the rest of the code. However, a coroutine is not bound to any particular thread. It may suspend its execution in one thread and resume in another one. Coroutines can be thought of as light-weight threads, but there is a number of important differences that make their real-life usage very different from threads. Run the following code to get to your first working coroutine: ```kotlin import kotlinx.coroutines.* //sampleStart fun main() = runBlocking { // this: CoroutineScope launch { // launch a new coroutine and continue delay(1000L) // non-blocking delay for 1 second (default time unit is ms) println("World!") // print after delay } println("Hello") // main coroutine continues while a previous one is delayed } //sampleEnd ``` {kotlin-runnable="true" kotlin-min-compiler-version="1.3"} > You can get the full code [here](../../kotlinx-coroutines-core/jvm/test/guide/example-basic-01.kt). > {type="note"} You will see the following result: ```text Hello World! ``` Let's dissect what this code does. [launch] is a _coroutine builder_. It launches a new coroutine concurrently with the rest of the code, which continues to work independently. That's why `Hello` has been printed first. [delay] is a special _suspending function_. It _suspends_ the coroutine for a specific time. Suspending a coroutine does not _block_ the underlying thread, but allows other coroutines to run and use the underlying thread for their code. [runBlocking] is also a coroutine builder that bridges the non-coroutine world of a regular `fun main()` and the code with coroutines inside of `runBlocking { ... }` curly braces. This is highlighted in an IDE by `this: CoroutineScope` hint right after the `runBlocking` opening curly brace. If you remove or forget `runBlocking` in this code, you'll get an error on the [launch] call, since `launch` is declared only in the [CoroutineScope]: ```Plain Text Unresolved reference: launch ``` The name of `runBlocking` means that the thread that runs it (in this case — the main thread) gets _blocked_ for the duration of the call, until all the coroutines inside `runBlocking { ... }` complete their execution. You will often see `runBlocking` used like that at the very top-level of the application and quite rarely inside the real code, as threads are expensive resources and blocking them is inefficient and is often not desired. ### Structured concurrency Coroutines follow a principle of **structured concurrency** which means that new coroutines can be only launched in a specific [CoroutineScope] which delimits the lifetime of the coroutine. The above example shows that [runBlocking] establishes the corresponding scope and that is why the previous example waits until `World!` is printed after a second's delay and only then exits. In the real application, you will be launching a lot of coroutines. Structured concurrency ensures that they are not lost and do not leak. An outer scope cannot complete until all its children coroutines complete. Structured concurrency also ensures that any errors in the code are properly reported and are never lost. ## Extract function refactoring Let's extract the block of code inside `launch { ... }` into a separate function. When you perform "Extract function" refactoring on this code, you get a new function with the `suspend` modifier. This is your first _suspending function_. Suspending functions can be used inside coroutines just like regular functions, but their additional feature is that they can, in turn, use other suspending functions (like `delay` in this example) to _suspend_ execution of a coroutine. ```kotlin import kotlinx.coroutines.* //sampleStart fun main() = runBlocking { // this: CoroutineScope launch { doWorld() } println("Hello") } // this is your first suspending function suspend fun doWorld() { delay(1000L) println("World!") } //sampleEnd ``` {kotlin-runnable="true" kotlin-min-compiler-version="1.3"} > You can get the full code [here](../../kotlinx-coroutines-core/jvm/test/guide/example-basic-02.kt). > {type="note"} ## Scope builder In addition to the coroutine scope provided by different builders, it is possible to declare your own scope using the [coroutineScope][_coroutineScope] builder. It creates a coroutine scope and does not complete until all launched children complete. [runBlocking] and [coroutineScope][_coroutineScope] builders may look similar because they both wait for their body and all its children to complete. The main difference is that the [runBlocking] method _blocks_ the current thread for waiting, while [coroutineScope][_coroutineScope] just suspends, releasing the underlying thread for other usages. Because of that difference, [runBlocking] is a regular function and [coroutineScope][_coroutineScope] is a suspending function. You can use `coroutineScope` from any suspending function. For example, you can move the concurrent printing of `Hello` and `World` into a `suspend fun doWorld()` function: ```kotlin import kotlinx.coroutines.* //sampleStart fun main() = runBlocking { doWorld() } suspend fun doWorld() = coroutineScope { // this: CoroutineScope launch { delay(1000L) println("World!") } println("Hello") } //sampleEnd ``` {kotlin-runnable="true" kotlin-min-compiler-version="1.3"} > You can get the full code [here](../../kotlinx-coroutines-core/jvm/test/guide/example-basic-03.kt). > {type="note"} This code also prints: ```text Hello World! ``` ## Scope builder and concurrency A [coroutineScope][_coroutineScope] builder can be used inside any suspending function to perform multiple concurrent operations. Let's launch two concurrent coroutines inside a `doWorld` suspending function: ```kotlin import kotlinx.coroutines.* //sampleStart // Sequentially executes doWorld followed by "Done" fun main() = runBlocking { doWorld() println("Done") } // Concurrently executes both sections suspend fun doWorld() = coroutineScope { // this: CoroutineScope launch { delay(2000L) println("World 2") } launch { delay(1000L) println("World 1") } println("Hello") } //sampleEnd ``` {kotlin-runnable="true" kotlin-min-compiler-version="1.3"} > You can get the full code [here](../../kotlinx-coroutines-core/jvm/test/guide/example-basic-04.kt). > {type="note"} Both pieces of code inside `launch { ... }` blocks execute _concurrently_, with `World 1` printed first, after a second from start, and `World 2` printed next, after two seconds from start. A [coroutineScope][_coroutineScope] in `doWorld` completes only after both are complete, so `doWorld` returns and allows `Done` string to be printed only after that: ```text Hello World 1 World 2 Done ``` ## An explicit job A [launch] coroutine builder returns a [Job] object that is a handle to the launched coroutine and can be used to explicitly wait for its completion. For example, you can wait for completion of the child coroutine and then print "Done" string: ```kotlin import kotlinx.coroutines.* fun main() = runBlocking { //sampleStart val job = launch { // launch a new coroutine and keep a reference to its Job delay(1000L) println("World!") } println("Hello") job.join() // wait until child coroutine completes println("Done") //sampleEnd } ``` {kotlin-runnable="true" kotlin-min-compiler-version="1.3"} > You can get the full code [here](../../kotlinx-coroutines-core/jvm/test/guide/example-basic-05.kt). > {type="note"} This code produces: ```text Hello World! Done ``` ## Coroutines ARE light-weight Run the following code: ```kotlin import kotlinx.coroutines.* //sampleStart fun main() = runBlocking { repeat(100_000) { // launch a lot of coroutines launch { delay(5000L) print(".") } } } //sampleEnd ``` > You can get the full code [here](../../kotlinx-coroutines-core/jvm/test/guide/example-basic-06.kt). > {type="note"} It launches 100K coroutines and, after 5 seconds, each coroutine prints a dot. Now, try that with threads (remove `runBlocking`, replace `launch` with `thread`, and replace `delay` with `Thread.sleep`). What would happen? (Most likely your code will produce some sort of out-of-memory error) [launch]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/launch.html [delay]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/delay.html [runBlocking]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-blocking.html [CoroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-coroutine-scope/index.html [_coroutineScope]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/coroutine-scope.html [Job]: https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/-job/index.html