中断ZStreammapMPar处理

使用ZStream的interrupt方法来中断mapMPar处理。

例如，我们可以使用ZStream的iterate方法生成10个整数，并对它们进行平方计算，然后使用mapMPar方法以并行方式将它们加倍，最后使用interrupt方法中断这个处理过程。

import zio.Task
import zio.stream._

object InterruptZStream {

  def main(args: Array[String]): Unit = {
    val integers: ZStream[Any, Nothing, Int] = ZStream.iterate(0)(_ + 1).take(10)
    val resultStream: ZStream[Any, Throwable, Int] = integers
      .map(n => {
        println(s"Calculating square of $n on ${Thread.currentThread().getName}")
        n * n
      })
      .mapMPar(4)(n => {
        Task {
          println(s"Calculating double of $n on ${Thread.currentThread().getName}")
          Thread.sleep(1000)
          n * 2
        }
      })

    val runtime = zio.Runtime.default
    val result = runtime.unsafeRun(resultStream.interrupt)

    println(s"Result: $result")
  }

}

在上面的示例中，我们使用了mapMPar(4)，这意味着我们想要使用4个并行线程来对结果进行加倍。我们还使用了interrupt方法来中断处理，它会立即停止处理并返回当前已处理的结果。