kotlinx.coroutines

0.21.1

fun main(args: Array<String>) = runBlocking{
    val dispatcher = newFixedThreadPoolContext(10, "myPool")

    val jobs = ArrayList<Job>()
    for (i in 1..10) {
        jobs.add(launch(dispatcher) {
            println("Running in ${Thread.currentThread().name}")
            Thread.sleep(2000)
        })
    }

    for (job in jobs) {
        job.join()
    }
}

Running in myPool-1
Running in myPool-2
Running in myPool-3
Running in myPool-4
Running in myPool-5
Running in myPool-6
Running in myPool-7
Running in myPool-8
Running in myPool-9
Running in myPool-10

fun processor(input: ReceiveChannel<A>): ReceiveChannel<B> = produce {
    input.consumeEach {
        ...
        send(...)
    }
}

ConflatedChannel

CompletableDeferred

enable

kotlin.experimental.coroutines = 'enable'

suspend

val lambda: suspend (String) -> Unit = { input: String -> /* body */ }

CoroutineDispatcher

UI

suspend fun sum(): Long

suspend fun consume(consumer: suspend (Long) -> Unit)

var sum = 0L
numbers.consume { sum += it }
return sum

numbers.consume

actor

kotlinx.coroutines

0.22

AbstractCoroutine

0.22

1.2.21

fun SomeReceiver.someFunction(parentJob: Job) {
    someNonSuspendingCode()
    setOnErrorListener { errorCode ->
        parentJob.cancel(SomeException(errorCode))
    }
}

suspend fun

parentJob

suspend fun SomeReceiver.someFunction() {
    val currentJob = coroutineContext[Job]!!
    someNonSuspendingCode()
    setOnErrorListener { errorCode ->
        currentJob.cancel(SomeException(errorCode))
    }
}

class LoggingLinkedListChannel<E>(private val tag: String): LinkedListChannel<E>() {
	override fun offerInternal(element: E): Any {
		println("[$tag] $element")
		return super.offerInternal(element)
	}
}
val chan = LoggingLinkedListChannel<Int>("tag") // was Channel<Int>(Channel.UNLIMITED)

.map { println(it); it }

fun <E> ReceiveChannel<E>.onEach(context: CoroutineContext = Unconfined, action: (E) -> Unit): ReceiveChannel<E> =
    produce(context) {
        consumeEach {
            action(it)
            send(it)
        }
    }