Daniel Elliott
c080f0d97f
- Added realracing3-community.apk (71.57 MB) - Removed 32-bit support (armeabi-v7a) - Only includes arm64-v8a libraries - Decompiled source code included - Added README-community.md with analysis
42 lines
2.4 KiB
Java
42 lines
2.4 KiB
Java
package kotlinx.coroutines;
|
|
|
|
import kotlin.coroutines.ContinuationInterceptor;
|
|
import kotlin.coroutines.CoroutineContext;
|
|
import kotlin.coroutines.EmptyCoroutineContext;
|
|
import kotlin.jvm.functions.Function2;
|
|
|
|
/* loaded from: classes5.dex */
|
|
public abstract /* synthetic */ class BuildersKt__BuildersKt {
|
|
public static /* synthetic */ Object runBlocking$default(CoroutineContext coroutineContext, Function2 function2, int i, Object obj) {
|
|
if ((i & 1) != 0) {
|
|
coroutineContext = EmptyCoroutineContext.INSTANCE;
|
|
}
|
|
return BuildersKt.runBlocking(coroutineContext, function2);
|
|
}
|
|
|
|
public static final Object runBlocking(CoroutineContext coroutineContext, Function2 function2) {
|
|
EventLoop currentOrNull$kotlinx_coroutines_core;
|
|
CoroutineContext newCoroutineContext;
|
|
Thread currentThread = Thread.currentThread();
|
|
ContinuationInterceptor continuationInterceptor = (ContinuationInterceptor) coroutineContext.get(ContinuationInterceptor.Key);
|
|
if (continuationInterceptor == null) {
|
|
currentOrNull$kotlinx_coroutines_core = ThreadLocalEventLoop.INSTANCE.getEventLoop$kotlinx_coroutines_core();
|
|
newCoroutineContext = CoroutineContextKt.newCoroutineContext(GlobalScope.INSTANCE, coroutineContext.plus(currentOrNull$kotlinx_coroutines_core));
|
|
} else {
|
|
EventLoop eventLoop = continuationInterceptor instanceof EventLoop ? (EventLoop) continuationInterceptor : null;
|
|
if (eventLoop != null) {
|
|
EventLoop eventLoop2 = eventLoop.shouldBeProcessedFromContext() ? eventLoop : null;
|
|
if (eventLoop2 != null) {
|
|
currentOrNull$kotlinx_coroutines_core = eventLoop2;
|
|
newCoroutineContext = CoroutineContextKt.newCoroutineContext(GlobalScope.INSTANCE, coroutineContext);
|
|
}
|
|
}
|
|
currentOrNull$kotlinx_coroutines_core = ThreadLocalEventLoop.INSTANCE.currentOrNull$kotlinx_coroutines_core();
|
|
newCoroutineContext = CoroutineContextKt.newCoroutineContext(GlobalScope.INSTANCE, coroutineContext);
|
|
}
|
|
BlockingCoroutine blockingCoroutine = new BlockingCoroutine(newCoroutineContext, currentThread, currentOrNull$kotlinx_coroutines_core);
|
|
blockingCoroutine.start(CoroutineStart.DEFAULT, blockingCoroutine, function2);
|
|
return blockingCoroutine.joinBlocking();
|
|
}
|
|
}
|