Реализация сокращения в Scala (Scala FP)

Я реализую метод reduce в Scala как упражнение по функциональному программированию в Scala, и не думаю, что он выполняется параллельно. Как создать его полностью параллельную реализацию?

  def reduce[A](pas: IndexedSeq[A])(f: (A, A) => A): Par[A] =
    if pas.isEmpty then throw new Exception("Can't reduce empty list")
    else if pas.size == 1 then unit(pas.head)
    else
      val (l, r) = pas.splitAt(pas.size / 2)
      reduce(l)(f).map2(reduce(r)(f))(f)

Я использую класс Par из книги:

object Par:
  opaque type Par[A] = ExecutorService => Future[A]

  extension [A](pa: Par[A]) def run(s: ExecutorService): Future[A] = pa(s)

  def fork[A](a: => Par[A]): Par[A] = 
    es => es.submit(new Callable[A] { def call = a(es).get })

  def lazyUnit[A](a: => A): Par[A] = fork(unit(a))