Эффект абстракции в Cats и параллельном исполнении - PullRequest
Новая
       9

Эффект абстракции в Cats и параллельном исполнении

0 голосов
/ 08 мая 2018

У меня есть следующий код, написанный с использованием Cats IO, который выполняет несколько действий параллельно (упрощенно): 

import cats.effect._
import cats.implicits._

import scala.concurrent.ExecutionContext.Implicits.global

    class ParallelExecIO {

        def exec: IO[List[String]] = {
            val foo = IO.shift *> IO("foo")
            val bar = IO.shift *> IO("bar")
            List(foo, bar).parSequence
        }
    }

Можно ли переписать этот код с помощью абстракции эффекта? Какие доказательства должны быть предоставлены?

Пример: 

class ParallelExecIO[F[_]: ConcurrentEffect /* ??? */] {

    def exec: F[List[String]] = {
        val foo = Async.shift[F](implicitly) *> "foo".pure[F]
        val bar = Async.shift[F](implicitly) *> "bar".pure[F]
        List(foo, bar).parSequence 
    }
}

[error] значение parSequence не является членом List [F [String]]

1 Ответ

0 голосов
/ 08 мая 2018

С 

scalaVersion := "2.12.5"
scalacOptions += "-Ypartial-unification"
libraryDependencies += "org.typelevel" %% "cats-core" % "1.1.0"
libraryDependencies += "org.typelevel" %% "cats-effect" % "0.10"

ошибка 

Error:(23, 22) could not find implicit value for parameter P: cats.Parallel[F,F]
      List(foo, bar).parSequence

Так что попробуйте 

import cats.Parallel
import cats.effect.{Async, ConcurrentEffect}
import cats.implicits._
import scala.concurrent.ExecutionContext.Implicits.global
import scala.language.higherKinds

class ParallelExecIO[F[_]: ConcurrentEffect, G[_]](implicit ev: Parallel[F, G]) {

  def exec: F[List[String]] = {
    val foo = Async.shift[F](implicitly) *> "foo".pure[F]
    val bar = Async.shift[F](implicitly) *> "bar".pure[F]
    List(foo, bar).parSequence
  }
}

Конечно, вы можете ввести type Parallel[F[_]] = cats.Parallel[F, F], и тогда это можно переписать как class ParallelExecIO[F[_]: ConcurrentEffect : Parallel] {...

...