feature: basic zio concurrency

This commit is contained in:
Abdellah El Morabit 2025-11-27 21:21:50 +01:00
parent 356d86e2a9
commit fe6dc1d84b
3 changed files with 39 additions and 21 deletions

View File

@ -2,21 +2,42 @@ package main
import Ops.* import Ops.*
import Tests.* import Tests.*
import tools.*
import java.time.Instant import java.time.Instant
import zio._
object Torque {
@main /*
def main(args: String*): Unit = { println("\u001b[2J\u001b[H") * *> = "Then" (think arrow pointing to what matters)
println("--- TORQUE STRESS TESTING UTILITY ---") * <&> = "Both" (symbol looks like things going in both directions)
* <* = "Keep left" (pointing to what you keep)
* &> = "Keep right" (pointing to what you keep)
* */
var cdt: CholeskyDecompositionTest = new CholeskyDecompositionTest object Torque extends ZIOAppDefault {
// returns an out of bounds error
// println(cdt.test())
var p: Prime = new Prime
p.run(1000000000, true)
} def runCholeskyTest: ZIO[Any, Throwable, Unit] =
ZIO.attempt {
val matrix: Vector[Vector[Int]] = Vector(Vector(1,2,3), Vector(1,2,3), Vector(1,2,3))
val cd = new CholeskyDecomposition
cd.run(matrix)
}.catchAll { error => Console.printError(s"failed: $error")}
def runPrimeTest: ZIO[Any, Throwable, Unit] =
ZIO.attempt {
val p = new Prime
p.run(390483094, true)
}.catchAll { error => Console.printError(s"failed: $error")}
def runSequential: ZIO[Any, Throwable, Unit] =
Console.printLine("sequential test") *>
runCholeskyTest *>
runPrimeTest
def runParallel: ZIO[Any, Throwable, Unit] =
Console.printLine("CholeskyTest") *>
(runCholeskyTest <&> runPrimeTest).unit
override def run: ZIO[ZIOAppArgs & Scope, Any, Any] = runParallel
} }

View File

@ -31,18 +31,15 @@ class Prime() {
* We want the function to be less optimized so that the CPU has more work == more stress * We want the function to be less optimized so that the CPU has more work == more stress
*/ */
def isPrime(n: Int): Boolean = {
if n <= 1 then false
else !(2 to math.sqrt(n).toInt).exists(i => n % i == 0)
}
def run(n: Int, result: Boolean): Unit = { def run(n: Int, result: Boolean): Unit = {
for i <- 0 to n do if isPrime(i) == result then println("true") else println("false") for i <- 0 to n do if isPrime(i) == result then println("true") else println("false")
} }
private def isPrime(n: Int): Boolean = {
if n <= 1 then false
else !(2 to math.sqrt(n).toInt).exists(i => n % i == 0)
}
} }
class Hash { class Hash {

View File

@ -5,7 +5,7 @@ import zio._
import main.Ops.CholeskyDecomposition import main.Ops.CholeskyDecomposition
class CholeskyDecompositionTest { class CholeskyDecompositionRunner {
def test(): Unit = { def test(): Unit = {