Concurrency IO

concurrent-execution-io.scala

val jobOne: IO[Int] = IO(1+1)
val jobTwo: IO[String] = IO(List("hello", "guys").mkString(" "))

// Concurrent execution (manually)
for {
  j1Fiber <- jobOne.start
  j2Fiber <- jobTwo.start
  i <- j1Fiber.join
  s <- j2Fiber.join
} yield (i, s)

// Concurrent execution (higher level)
val result2: IO[(Int, String)] = (jobOne, jobTwo).parTupled

fiber-blocking-canelling.scala

import cats.effect._
import cats.effect.unsafe.implicits.global
import scala.concurrent.duration._

val program = for {
	fiber <- IO.println(Thread.currentThread().getId).foreverM.start
	_ <- IO.sleep(1.seconds)
	_ <- fiber.cancel
} yield ()

program.unsafeRunSync()