dispatcher

dispatcher.scala

  test("dispatcher.parallel") {
    val a1 = IO.println("a1 start") >> IO.sleep(3.seconds) >> IO.println("a1 done")
    val a2 = IO.println("a2 start") >> IO.sleep(1.seconds) >> IO.println("a2 done")

    Dispatcher.parallel[IO].use { dispatcher =>
      IO {
        dispatcher.unsafeRunAndForget(a1)
        dispatcher.unsafeRunAndForget(a2)
      } >> IO.sleep(5.seconds)
    }.unsafeRunSync()
  }

// print
a2 start
a1 start
a2 done
a1 done


  test("dispatcher.sequential") {
    val a1 = IO.println("a1 start") >> IO.sleep(3.seconds) >> IO.println("a1 done")
    val a2 = IO.println("a2 start") >> IO.sleep(1.seconds) >> IO.println("a2 done")

    Dispatcher.sequential[IO].use { dispatcher =>
      IO {
        dispatcher.unsafeRunAndForget(a1)
        dispatcher.unsafeRunAndForget(a2)
      } >> IO.sleep(5.seconds)
    }.unsafeRunSync()
  }

// print
a1 start
a1 done
a2 start
a2 done