Created
March 21, 2022 19:29
-
-
Save vasmarfas/c009188608b048de99e6aac6d489166d to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import kotlinx.coroutines.withTimeout | |
| import kotlinx.coroutines.yield | |
| import java.math.BigInteger | |
| import kotlin.coroutines.resume | |
| import kotlin.coroutines.resumeWithException | |
| import kotlin.coroutines.suspendCoroutine | |
| object Fibonacci { | |
| suspend fun take(n: Int) { | |
| yield() | |
| withTimeout(3000) { | |
| suspendCoroutine<BigInteger> { continuation -> | |
| calculate(object : Callback { | |
| override fun onSuccess(value: BigInteger) { | |
| println("Calculated number from ${Thread.currentThread().name} - $value") | |
| continuation.resume(value) | |
| } | |
| override fun onFailure(error: Throwable) { | |
| println("error - ${error.message}") | |
| continuation.resumeWithException(error) | |
| } | |
| }, n) | |
| } | |
| } | |
| } | |
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import kotlinx.coroutines.launch | |
| import kotlinx.coroutines.runBlocking | |
| import kotlinx.coroutines.withTimeout | |
| import kotlinx.coroutines.yield | |
| import java.math.BigInteger | |
| import kotlin.concurrent.thread | |
| import kotlin.coroutines.resume | |
| import kotlin.coroutines.resumeWithException | |
| import kotlin.coroutines.suspendCoroutine | |
| fun main() = runBlocking { | |
| println("Program start: ${Thread.currentThread().name}") | |
| launch { | |
| take(1) | |
| } | |
| launch { | |
| take(2) | |
| } | |
| launch { | |
| take(70) | |
| } | |
| println("Program finished.") | |
| } | |
| fun calculate(callback: Callback, n: Int) { | |
| thread { | |
| println("Calculation start: ${Thread.currentThread().name}") | |
| var first: Int = 0 | |
| var second: Int = 1 | |
| var i = 0 | |
| var sum: Int | |
| do { | |
| sum = first + second | |
| first = second | |
| second = sum | |
| i++ | |
| } while (i <= n - 2) | |
| callback.onSuccess(sum.toBigInteger()) | |
| } | |
| } | |
| suspend fun take(n: Int) { | |
| // yield() | |
| withTimeout(3000) { | |
| suspendCoroutine<BigInteger> { continuation -> | |
| calculate(object : Callback { | |
| override fun onSuccess(value: BigInteger) { | |
| println("Calculated number from ${Thread.currentThread().name} - $value") | |
| continuation.resume(value) | |
| } | |
| override fun onFailure(error: Throwable) { | |
| println("error - ${error.message}") | |
| continuation.resumeWithException(error) | |
| } | |
| }, n) | |
| } | |
| } | |
| } | |
| interface Callback { | |
| fun onSuccess(value: BigInteger) | |
| fun onFailure(error: Throwable) | |
| } | |
| //] |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment