- Supported on Native and JVM
- Kotlin 1.3.31
This library helps unify and support coroutine background thread usage in common code for Kotlin/Native, until kotlinx.coroutines has support for native, multi-threaded coroutines. This library doesn't support every use case (but could support more with your help!), but it does support some useful ones:
val worker = CoroutineWorker.execute {
// - In here, `this` is a `CoroutineScope`
// - Run suspend functions, call launch, etc.
// - This code runs in a thread pool
}
// Tells the worker to cancel (uses standard coroutine cancellation)
worker.cancel()
// Tells the worker to cancel; it suspends until cancellation is finished
worker.cancelAndJoin()val result = CoroutineWorker.performAndWait {
// This is similar to execute, but it returns
// the result of the work at the end of this lambda
1
}
print(result) // prints 1- Use
threadSafeSuspendCallbackto bridge callback-style async work out to your platform back into your library as asuspend fun(see example usages in the library).
- Closures passed to
executeandperformAndWaitare automatically frozen, so be careful about what your closure captures (e.g. implicit references tothis)! - The result value from
performAndWaitis also frozen.