我尝试在Scala.js中使用Promise和Future。 Promise可以正常工作,但是一旦涉及到Future时,我会收到警告和错误信息。
尝试:
尝试:
val p1 = Promise[Int]
val f1: Future[Int] = p1.future
val p2 = Promise[Int]
val f2: Future[Int] = p2.future
val res1 = for {
v1 <- f1
v2 <- f2
} yield v1 + v2
val res2 = f1.flatMap(x => f2.map(y => x + y))
res1 onSuccess {
case x: Int => g.console.log(x);
}
res2 onSuccess {
case x: Int => g.console.log(x);
}
// callback in dom, using ScalaTags
// div(`class` := "btn btn-default", `type` := "button", onclick := click(1, p1))
def click(i: Int, p: Promise[Int])(x: dom.MouseEvent): Unit = {
g.console.log(i);
try {
p success i
}
catch {
case x: Throwable => println("again")
}
}
f1 onSuccess {
case x: Int => 1
}
我执行sbt fastOptJs命令:
[warn] Referring to non-existent class jl_Thread$UncaughtExceptionHandler
[warn] called from s_concurrent_impl_ExecutionContextImpl.init___ju_concurrent_Executor__F1
[warn] called from s_concurrent_impl_ExecutionContextImpl$.fromExecutor__ju_concurrent_Executor__F1__s_concurrent_impl_ExecutionContextImpl
[warn] called from s_concurrent_ExecutionContext$Implicits$.global$lzycompute__p1__s_concurrent_ExecutionContextExecutor
[warn] called from s_concurrent_ExecutionContext$Implicits$.global__s_concurrent_ExecutionContextExecutor
[warn] called from Lexample_H2$class.Lexample_H2$class__$init$__Lexample_H2__V
[warn]
我在浏览器中看到:
uncaught exception: java.lang.RuntimeException: System.getProperty() not implemented
缺少/未实现什么?如何实现它?有没有解决方法?如何实现一个在浏览器内处理事件的ExecutionContext,使其具有意义?
queue
可以使用 promises 或者 timeouts(用于不支持 promises 的老浏览器)实现。 - Sumaqueue
是异步的,意味着代码稍后执行(使用已解决的 Promise 或 setTimeout 上的 then),但代码不会并行运行。对于真正的“并行”(并发)任务,您需要 Web Workers,例如使用来自 github.com/nolanlawson/promise-worker 的库。或者我理解错了吗? - SumaPromise
和Future
不会并行执行。如果需要并行处理,必须使用 Web Workers,但这样会失去共享内存,这从根本上改变了事物的工作方式。 - sjrd