InsanusMokrassar/MicroUtils
1
0
Fork 0
mirror of https://github.com/InsanusMokrassar/MicroUtils.git synced 2024-11-19 23:03:49 +00:00
Code Issues Packages Projects Releases Wiki Activity

rewrite launchSynchronously

Browse Source
This commit is contained in:
InsanusMokrassar 2021-04-20 21:39:21 +06:00
parent 7f813a519b
commit 9e02c3e5ff
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
coroutines/src/jvmMain/kotlin/dev/inmo/micro_utils/coroutines/LaunchSynchronously.kt
View File

@ -3,17 +3,16 @@ package dev.inmo.micro_utils.coroutines
import kotlinx.coroutines.* import kotlinx.coroutines.*
fun <T> CoroutineScope.launchSynchronously(block: suspend CoroutineScope.() -> T): T { fun <T> CoroutineScope.launchSynchronously(block: suspend CoroutineScope.() -> T): T {
var throwable: Throwable? = null val deferred = CompletableDeferred<T>()
var result: T? = null
val objectToSynchronize = java.lang.Object() val objectToSynchronize = java.lang.Object()
val launchCallback = { val launchCallback = {
launch { launch {
safely( safely(
{ {
throwable = it deferred.completeExceptionally(it)
} }
) { ) {
result = block() deferred.complete(block())
} }
synchronized(objectToSynchronize) { synchronized(objectToSynchronize) {
objectToSynchronize.notifyAll() objectToSynchronize.notifyAll()
@ -24,7 +23,7 @@ fun <T> CoroutineScope.launchSynchronously(block: suspend CoroutineScope.() -> T
launchCallback() launchCallback()
objectToSynchronize.wait() objectToSynchronize.wait()
} }
throw throwable ?: return result!! return deferred.getCompleted()
} }
fun <T> launchSynchronously(block: suspend CoroutineScope.() -> T): T = CoroutineScope(Dispatchers.Default).launchSynchronously(block) fun <T> launchSynchronously(block: suspend CoroutineScope.() -> T): T = CoroutineScope(Dispatchers.Default).launchSynchronously(block)