| /* |
| * Copyright 2016-2021 JetBrains s.r.o. Use of this source code is governed by the Apache 2.0 license. |
| */ |
| |
| package kotlinx.coroutines |
| |
| import kotlinx.cinterop.* |
| import kotlinx.coroutines.internal.* |
| import kotlinx.coroutines.internal.multithreadingSupported |
| import platform.posix.* |
| import kotlin.coroutines.* |
| import kotlin.native.concurrent.* |
| import kotlin.system.* |
| |
| internal actual abstract class EventLoopImplPlatform : EventLoop() { |
| |
| private val current = Worker.current |
| |
| protected actual fun unpark() { |
| current.executeAfter(0L, {})// send an empty task to unpark the waiting event loop |
| } |
| |
| protected actual fun reschedule(now: Long, delayedTask: EventLoopImplBase.DelayedTask) { |
| if (multithreadingSupported) { |
| DefaultExecutor.invokeOnTimeout(now, delayedTask, EmptyCoroutineContext) |
| } else { |
| error("Cannot execute task because event loop was shut down") |
| } |
| } |
| } |
| |
| internal class EventLoopImpl: EventLoopImplBase() { |
| override fun invokeOnTimeout(timeMillis: Long, block: Runnable, context: CoroutineContext): DisposableHandle { |
| if (!multithreadingSupported) { |
| return scheduleInvokeOnTimeout(timeMillis, block) |
| } |
| return DefaultDelay.invokeOnTimeout(timeMillis, block, context) |
| } |
| } |
| |
| internal actual fun createEventLoop(): EventLoop = EventLoopImpl() |
| |
| internal actual fun nanoTime(): Long = getTimeNanos() |