2

我正在尝试构建一个协程框架，以通过并行遍历每个数据相关函数来启用批量数据获取。这是我到目前为止所拥有的：http: //pastie.org/7147798

  1. 这不起作用

    def get(id: Long) = reset {
  // Is it not already cached?
  if (!cached.isDefinedAt(id)) {
    // Store the ID we want to fetch.
    queued += id
    // Come back later...
    shift { fetch[Object]() } : Seq[Any] @cps[ExecState[Object]]
  }
  // We should have the ID fetched now.
  Result(cached(id))
}

    我收到以下错误

    ashoat@ashoatmbp [~/project]# scala -P:continuations:enable Loader.scala
/Users/ashoat/project/Loader.scala:134: error: type mismatch;
 found   : Unit
 required: Any @util.continuations.package.cps[Main.$anon.Loader.ExecState[Main.$anon.Loader.Object]]
      if (!cached.isDefinedAt(id)) {
      ^
one error found

    这有效

    def get(id: Long) = reset {
  // Is it not already cached?
  if (!cached.isDefinedAt(id)) {
    // Store the ID we want to fetch.
    queued += id
    // Come back later...
    shift { fetch[Object]() } : Seq[Any] @cps[ExecState[Object]]
    // We should have the ID fetched now.
    Result(cached(id))
  } else {
    // We should have the ID fetched now.
    Result(cached(id))
  }
}

  2. 这不起作用

    val getFive = reset {
  if (true) {
    Result(5)
  } else {
    val seq: Seq[Any] = shift { fetch[Int](Object.get(15181990251L)) }
    val Seq(obj: Object) = seq
    Result(obj.fields("test").toInt)
  }
}

    我收到以下错误

    ashoat@ashoatmbp [~/project]# scala -P:continuations:enable Loader.scala
/Users/ashoat/project/Loader.scala:170: error: cannot cps-transform expression new this.Loader.Result[Int](5): type arguments [this.Loader.Result[Int],this.Loader.Result[Int],Nothing] do not conform to method shiftUnit's type parameter bounds [A,B,C >: B]
    Result(5)// : Result[Int] @cps[Result[Int]]
          ^
one error found

    这有效

    val getFive = reset {
  if (true) {
    Result(5) : Result[Int] @cps[Result[Int]]
  } else {
    val seq: Seq[Any] = shift { fetch[Int](Object.get(15181990251L)) }
    val Seq(obj: Object) = seq
    Result(obj.fields("test").toInt)
  }
}

    但我收到以下警告

    ashoat@ashoatmbp [~/project]# scala -P:continuations:enable Loader.scala
/Users/ashoat/project/Loader.scala:170: warning: expression (new this.Loader.Result[Int](5): this.Loader.Result[Int]) is cps-transformed unexpectedly
    Result(5) : Result[Int] @cps[Result[Int]]
              ^
one warning found
8
4

1 回答 1

1

尽管我自己仍然不太了解延续，但据我所知，您示例中的关键问题是您的代码并不总是shift向reset.

编译器希望找到一些shift嵌套在reset. 然后它会将 CPS 转换shift为 a以及在转换为调用ControlContext][A, B, C]之后发生的代码。shiftControlContext.map

因为您有一个语句，所以在采用elseif分支的情况下，没有嵌套：shift

reset {
  if (false) {
    shift { ... }
  } 
  Result(cached(id)) // no shift
}

与

reset {
  if (false) {
    shift { ... }
  } else {
    Result(cached(id)) // no shift
  }
}

这不能转换为有效的 CPS 代码。

看来您可以在 if 分支内进行重置，或者向 else 分支提供一个简单的 shift 语句：

if (!cached.isDefinedAt(id)) reset {
   shift { ... }
   Result(cached(id))
} else {
   Result(cached(id))
}

// or

reset {
  if (!cached.isDefinedAt(id)) {
    shift { ... }
    Result(cached(id))
  } else {
    shift[Result[Object], ExecState[Object], ExecState[Object]] { k => 
      Result(cached(id))
    }
  }
}

编辑：似乎 cps 插件如何推断类型存在一些不一致之处。例如：

var b = false
def test[A](a: A) = reset {
  if (b) {
    a
  } else {
    shift{ (k: Unit => A) => k() }
    a
  }
}

使用选项运行编译-Xprint:selectivecps表明编译器推断类型，Reset[A, Nothing]然后运行代码将在运行时产生错误。如果if反转为：

var b = false
def test[A](a: A) = reset {
  if (b) {
    shift{ (k: Unit => A) => k() }
    a
  } else {
    a
  }
}

然后编译器正确推断reset[A, A]. 如果我提供reset喜欢的类型参数，test[A](a: A) = reset[A, A] {那么它在这两种情况下都有效。

也许将类型参数指定为resetandshift而不是 using Result(5)，使用该shiftUnit[A, B, C]方法将有助于减少不一致。

于 2013-03-29T07:28:23.520 回答