How to Run Different Functions in Parallel Scala

Question

How to run in parallel the two different functions that returns different datatype?

Here we have fruitFutures, and primeFutures. How can I utilize the Await.result function?

val fruits = List("apple", "orange", "mango", "banana")
val primeNums = List(2,3,5,7,11)

def executeFruit(fruit: String): Try[String] = {
  Try {
   s"executed $fruit"
  }
}

def executePrime(prime: Int): Try[Int] = {
  Try {
    prime * 2
  }
}

val fruitFutures: List[Future[Try[String]]] = for {
     fruit <- fruits
   } yield {
     Future {
      executeFruit(fruit)
     }
   }

val primeFutures: List[Future[Try[Int]]] = for {
     prime <- primeNums
   } yield {
     Future {
      executePrime(prime)
     }
   }

val futureResults = Await.result(Future.sequence(???), Duration.Inf)

future.sequence(fruitFuture ++ primeFuture).map( //do your thing) — Raman Mishra
– Raman Mishra, Commented Mar 31, 2021 at 7:47
Thanks, but it's giving me Product with Serializable so not sure how to work with this. — Anime Lover
– Anime Lover, Commented Mar 31, 2021 at 7:59

nbsoluren · Accepted Answer · 2021-03-31 07:57:55Z

2

You can try this:

    val futureResults = for {
      f <- Future.sequence(fruitFutures)
      p <- Future.sequence(primeFutures)
    } yield (f, p)
    val (fruitResult, primeResult) =
      Await.result(futureResults, Duration.Inf)

This will result:

List(Success(executed apple), Success(executed orange), Success(executed mango), Success(executed banana))
List(Success(4), Success(6), Success(10), Success(14), Success(22))

answered Mar 31, 2021 at 7:57

nbsoluren

362 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

How to Run Different Functions in Parallel Scala

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related