Skip to content

Instantly share code, notes, and snippets.

@dacr
Last active May 6, 2023 15:39
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save dacr/598ec0a4ed6005cd521aef529abef7b9 to your computer and use it in GitHub Desktop.
Save dacr/598ec0a4ed6005cd521aef529abef7b9 to your computer and use it in GitHub Desktop.
ZIO learning - garbage collected fibers / published by https://github.com/dacr/code-examples-manager #13f4a62f-c2ec-4405-a710-1444844f1592/a505f298f7ebc55f54749ae566157085f00f35ee
// summary : ZIO learning - garbage collected fibers
// keywords : scala, zio, learning, pure-functional, @testable
// publish : gist
// authors : David Crosson
// license : Apache NON-AI License Version 2.0 (https://raw.githubusercontent.com/non-ai-licenses/non-ai-licenses/main/NON-AI-APACHE2)
// id : 13f4a62f-c2ec-4405-a710-1444844f1592
// created-on : 2021-04-06T09:46:48+02:00
// managed-by : https://github.com/dacr/code-examples-manager
// run-with : scala-cli $file
// ---------------------
//> using scala "3.2.2"
//> using dep "dev.zio::zio:2.0.13"
// ---------------------
/*
inspired from
- [John A De Goes - ZIO: Next-Generation Effects in Scala](https://www.youtube.com/watch?v=mkSHhsJXjdc)
- +23:30
*/
import zio.*
object Encapsulated extends ZIOAppDefault {
val logic = for {
queue <- Queue.bounded[Int](100)
fiber <- queue.take.flatMap(v => Console.printLine(s"$v ")).forever.fork
_ <- ZIO.foreach(0 to 100)(queue.offer(_)).forever
} yield ()
def run = logic.timeout(Duration.fromMillis(5000)) // Just to avoid this script to run infinitly...
}
// infinitely running fiber... which will be garbage collected
// (unlike threads which required to be stopped !)
// -------------------------------------------------------------
Encapsulated.main(Array.empty)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment