Scala未来模式中的onComplete方法
是Future类的一个方法，用于注册一个回调函数，以处理Future完成后的结果。该方法接受一个回调函数作为参数，该回调函数会在Future完成时被调用，并传入一个Try类型的参数，表示Future的结果。
在回调函数中，可以根据Try的结果进行相应的处理，例如处理成功的结果或处理失败的异常。通过onComplete方法，可以实现对异步操作的结果进行处理，而不需要阻塞线程等待结果返回。
Scala未来模式中的onComplete方法的语法如下：
future.onComplete {
case Success(result) => // 处理成功的结果
case Failure(exception) => // 处理失败的异常
}应用场景：
- 异步操作：当需要执行一个耗时的操作，但又不希望阻塞当前线程时，可以使用Scala未来模式中的onComplete方法来处理异步操作的结果。
- 并发编程：在并发编程中，可以使用Scala未来模式中的onComplete方法来处理多个Future的结果，以便在所有Future完成后执行相应的操作。
推荐的腾讯云相关产品： 腾讯云提供了一系列云计算相关的产品和服务，以下是一些与Scala未来模式中的onComplete方法相关的产品：
- 云服务器（CVM）：提供弹性计算能力，可用于部署Scala应用程序。
- 弹性MapReduce（EMR）：提供大数据处理能力，可用于处理Scala未来模式中的onComplete方法返回的结果。
- 云数据库MySQL版（CDB）：提供可靠的数据库存储，可用于存储Scala未来模式中的onComplete方法的结果数据。
更多腾讯云产品信息，请访问腾讯云官方网站：https://cloud.tencent.com/
相关·内容
我是scala的初学者，我正在尝试理解以下语法：
val f = Future {
Thread.sleep(Random.nextInt(500))
42
}
println("2- before onComplete")
f.onComplete {
case Success(value) => println(s"Got the callback, meaning = $value")
case Failure(e) => e.printStackTrace
}
请解释一下Future{...}和onComplete{...}
浏览 15提问于2020-03-10得票数 0
回答已采纳
最近，在Akka演员中创建的scala.concurrent.Future对象正在经历一些超时，我想知道如何处理这些超时事件。他们真的迷路了吗？它们是否被重新尝试并保存在记忆中，或者是如何工作的？
为了提供一些上下文，代码如下所示。
List<Future<MyMessage>> futureMessageList = plainMessages.stream()
.map(this::toFuture)
.collect(Collectors.toList());
Futures.sequence(futureMessageList, Exe
浏览 0提问于2020-04-14得票数 0
回答已采纳
请原谅我对Scala不太了解。我只是一个Java开发人员，希望在Play Framework中得到一些有用的东西。我甚至试图使用Java代码实现一个特性，但是我得到了更多的模糊错误。我有以下Scala代码：
package models
import scala.concurrent.Future
class SettableFuture[T](name: String) extends Future[T] {
var assignedValue: T
def set(newValue: T) =
assignedValue = newValue
浏览 7提问于2013-11-01得票数 0
回答已采纳
import scala.sys.process._
import scala.concurrent._ // (future)
import ExecutionContext.Implicits.global // (future)
/* run "ls /opt"
* which outputs 2 lines:
* - "X11"
* - "local"
*/
val command = Process(Seq("ls", "/opt"), None, "LANG" ->
浏览 2提问于2015-07-23得票数 1
我正在学习一些未来的例子。我有一个未来，它从一个方法中检索一个列表。我调用两种不同类型的回调，Foreach回调和onComplete回调只是为了尝试它们。
Foreach回调几乎每次都返回列表。
即使For回调返回了列表，onComplete回调也很少返回成功。
onComplete回调永远不会返回失败。
有人能给我解释一下发生了什么吗？
我知道回调是并发执行的，并且没有订单。但是，如果未来将列表返回Foreach，而onComplete回调在Foreach和未来之前执行，并且试图从不成功的未来获得列表，那么onComplete回调返回失败不应该吗？
import sca
浏览 0提问于2019-06-06得票数 1
回答已采纳
我正在尝试进行大量的外部服务调用，每次调用之后都会进行异常处理和条件处理。我认为使用内部的扩展这个不错的( .onComplete )示例很容易，但我似乎不了解关于范围界定和/或期货的一些内容。谁能给我指明正确的方向吗？
#!/bin/bash
scala -feature $0 $@
exit
!#
import scala.concurrent.{future, blocking, Future, Await}
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duratio
浏览 3提问于2014-04-29得票数 2
回答已采纳
当我们在Scala中使用一个未来时，我想知道onComplete和foreach之间的区别。
f onComplete (_ => doSomething(_))
和
f foreach (_ => doSomething(_))
上面的代码行会导致相同的结果吗？
如果我想doSomething与未来f，只有在它完成后。我该怎么办？我是否应该像这样使用isCompleted：
if(f.isCompleted) f onComplete (_ => doSomething(_))
非常感谢你们
浏览 2提问于2016-04-23得票数 13
回答已采纳
我正在阅读Scala中关于期货和承诺的文章，并编写了以下代码：
def printSomething(): Future[String] = {
val p = Promise[String]
val sayHello = future {
Thread.sleep(1000)
p.success("hello")
}
p.future
}
def main(args: Array[String]) {
val something: Future[String] = printSomething()
something onComple
浏览 0提问于2013-11-26得票数 3
回答已采纳
我不知道说什么才好。连续第二天，我尝试从JSON对象中获得值，同时处理许多Scala库。这个是Akka和spray。我试图将id保存到变量的位置，并从函数/方法中返回。对于我来说，不管是不是Future，我都不在乎，但我坚持这个声明，int = for {lel <- ss} yield lel。无论我尝试什么，我总是得到int的初始值，无论它是类、case类、FutureInt还是Int。请指点。
scala> def queryLocation(location: String): Future[Int] = {
| var int: Any = Futur
浏览 1提问于2021-05-11得票数 0
回答已采纳
我正在尝试理解scala未来中的高阶函数。我写了这段代码
import scala.concurrent.Future
import scala.util.{Failure, Success}
import scala.concurrent.ExecutionContext.Implicits.global
object App30 extends App {
def getMilk(): String = {
val ans = "5 gallons of milk"
ans
}
def getFlour(): String =
{
浏览 0提问于2017-10-06得票数 0
1回答
这个Scala方法(应该返回Future[play.api.mvc.Result])调用另一个方法run，这是一个可能引发异常的未来。如果run不抛出异常，那么该方法应该返回ret等于0的Json。如果run确实抛出了一个异常，那么该方法应该使用ret等于1重定向Json。
问题是OnComplete抛出了一个编译错误：
类型错配；已发现:所需单位: scala.concurrent.Futureplay.api.mvc.Result
怎么解决这个问题？
def test (req:Int) : Future[play.api.mvc.Result] = {
va
浏览 3提问于2017-07-06得票数 0
回答已采纳
在使用Future.map处理第一个Future之后，一旦Future.onComplete被调用，第二个依赖的Future总是Future(<not completed>)。其他使用两个Future的构造从来没有表现出这种行为。
有人能解释为什么Future.onComplete被调用，尽管未来显然还没有完成吗？
使用Scala2.12.3。如果需要的话，剪切并粘贴以下内容来评估这个问题。
import scala.collection.mutable.ListBuffer
import scala.concurrent.ExecutionContext.Implicits.gl
浏览 1提问于2017-12-05得票数 0
回答已采纳
2回答
我对并行执行和scala非常陌生。关于使用scala中的未来，我有几个问题。
我相信，未来允许异步并行执行。据我所知，在下面的代码中，donutStock方法将在一个单独的线程上运行。官方文件还说，它不会阻塞主线程。因此，如果主线程没有被阻塞，那么新的子线程和主线程应该并行执行。
因此，在下面的示例中，我期望在调用donutStock方法时，主线程上的控件应该向前推进，然后主线程应该在另一个线程上调用第二个donutStock方法。
但是，我注意到第二个方法是在第一个调用完成后才调用的。我对非阻塞或异步的理解是正确的吗？如果我想执行这两个方法调用是并行的，那么正确的方法是什么。
我读到我们应该
浏览 4提问于2020-05-02得票数 1
回答已采纳
1回答
我希望下面的代码将生成值5，正如我编写的恢复来处理异常并返回5。但是我总是在IntelliJ中看到异常。这里的错误是什么？
import scala.concurrent._
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{Failure, Success, Try}
import scala.concurrent.duration._
import scala.language.postfixOps
object ConcurrencyExample extends App {
va
浏览 2提问于2016-12-30得票数 1
回答已采纳
2回答
我对Scala非常陌生，并遵循Scala并发部分(来自docs.scala-lang.org)。基于他们在书中给出的例子，我编写了一个非常简单的代码块来使用Futures.com进行测试：
import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{Failure, Success}
object Main {
def main(args: Array[String]): Unit = {
val a = Future{Thr
浏览 3提问于2022-06-03得票数 2
回答已采纳
1回答
我不明白为什么Scala的Future比Twitter更难使用，功能也更少，而第一个是在第二个之后创建的。下面是关于scala.concurrent.Future的问题
为什么Future.onComplete返回Unit而不是Future？可组合方法要方便得多。
为什么Scala的Future不支持取消？
浏览 0提问于2016-02-27得票数 3
回答已采纳
3回答
据我所知，Future是只读的，Promise是一次写入的数据结构.
我们需要一个Promise来完成一个Future
例如,
object Lie extends Throwable
val lie = Future { throw Lie }
val guess = Promise[String]()
lie.onComplete { case Success(s) => guess.success("I knew it was true!")
case Failure(t) => guess.failure
浏览 7提问于2016-10-30得票数 5
回答已采纳
我有这样的代码，在Scala中我正在发出一个问询请求：
someActorRef ? SomeMessage()
然而，我得到了这样的信息：
could not find implicit value for parameter timeout: akka.util.Timeout
我也试过这个：
Await.ready(someActorRef ? SomeMessage(), Duration("3 seconds")).asInstanceOf[String]
但我也收到了同样的信息。
不管怎样，我不想挡着你。我想得到一个Future，然后再给它一个onComplete回
浏览 2提问于2016-12-15得票数 2
回答已采纳
1回答
我正在学习akka/scala，并试图只读那些从Future中成功但无法工作的Seq[Future[Int]]。
我模拟了一个由10 Future[Int]组成的数组，其中一些是失败的，这取决于FailThreshold所取的值(全部失败10，0没有失败)。
然后，我尝试将它们读入一个ArrayBuffer (无法找到一种方法来返回带有值的不可变结构)。
此外，对于成功/失败没有过滤器，因此必须在每个未来运行一个onComplete，并作为副作用更新缓冲区。
即使当FailThreshold=0和Seq将所有未来设置为成功时，数组缓冲区有时也是空的，不同的运行返回不同大小的数组
浏览 0提问于2019-08-11得票数 1
回答已采纳
1回答
我想完成一些行动一次，当两个承诺是成功。所以我创建了这样一段代码：
val promiseForPersistence = Promise[Unit]()
val promiseForReplication = Promise[Unit]()
promiseForPersistence.future.onComplete {
case scala.util.Success(_) => {
if (promiseForReplication.isCompleted) {
println(s"Acking from persistence promise (
浏览 2提问于2014-01-01得票数 2
回答已采纳
我有spark scala应用程序。我正在尝试使用它内部的Futures来并行化几个独立的操作集。我在期货中调用它们，它们返回给我未来类型的DataFrame，我如何在最后合并它们，并在任何未来类型无法计算的情况下抛出错误。下面是我的代码。当我尝试在onComplete块中应用数据帧的联合时，它显示以下错误
value union is not a member of scala.concurrent.Future[(scala.concurrent.Future[org.apache.spark.sql.DataFrame], scala.concurrent.Future[org.apac
浏览 2提问于2020-01-22得票数 0
2回答
当使用如下代码时：
scala> Future { null } onComplete { case Success(v) => v.toString }
Scala抛出以下异常：
scala> java.lang.NullPointerException
at $line14.$read$$iw$$iw$$anonfun$2.apply(<console>:11)
at $line14.$read$$iw$$iw$$anonfun$2.apply(<console>:11)
at scala.concurrent.im
浏览 9提问于2014-09-07得票数 1
回答已采纳
我如何在Scala中构造onComplete来这样做：
图1
{
var x;
if(result.isFailure){
x = foo() // foo is a future
}
if(result.isSuccess){
x = 5
}
bar(x)
}
我想我可以这样做：
图2
var x = foo onComplete {
case Success(x) => 5
case Failure(t) => foo() //foo is a future
}
bar(x)
但是onComplete、onFailure
浏览 0提问于2015-09-01得票数 17
回答已采纳
如何从onComplete成功案例中返回值，以便打印hello值？
目前，我成功地获得了具有正确值的查询响应，并且我可以在onComplete成功案例中处理它，这样我就可以打印正确的响应值。
import ing.wbaa.druid.SQLQuery
import scala.concurrent.ExecutionContext
import scala.util.{Failure, Success}
implicit val executionContext: ExecutionContext = ExecutionContext.Implicits.global
val quer
浏览 0提问于2020-10-30得票数 1
4回答
我想测试一个返回Future的方法。我的尝试如下：
import org.specs2.mutable.Specification
import scala.concurrent.ExecutionContext.Implicits.global
import scala.util.{Failure, Success}
class AsyncWebClientSpec extends Specification{
"WebClient when downloading images" should {
"for a valid link return
浏览 5提问于2015-01-02得票数 20
回答已采纳
我有一个源源不断的类，它的定义如下：
abstract class StreamWrapper() {
def doStuff: Future[Unit] = ???
def recursiveStream(): Unit =
events.mapAsync(parallelism)(doStuff)
.runWith(Sink.fold(???))
.onComplete(
actorSystem.scheduler.scheduleOnce(delay)(recursiveStream())
浏览 0提问于2018-11-08得票数 0
我正在使用Scala驱动程序编写一个关于Play框架和MongoDB的简单博客。所以它起作用了，我很高兴，但是我觉得我的代码不够好。你们能否回顾一下下面的片段，这是我的mongo服务方法之一，并告诉我是否有办法使它更干净：
def findByTitle(title:String)(implicit ec:ExecutionContext):Future[Option[Document]] = {
val collection = db.getCollection("items")
val results = collection.find(equal("
浏览 6提问于2016-07-16得票数 12
回答已采纳
我在用Scala
我有一个返回对象的方法，在这个方法中，我使用未来与onComlpete回调
def xyzFunction (id : Int) : Abc = {
var abcObj = new Abc
var RetunedLists = new MutableList[ArtistImpl]()
val future:Future[MutableList[Abc]] = ask(SomeActor,Message(id)).mapTo[MutableList[Abc]]
future.onComplete {
case Success(resul
浏览 3提问于2015-08-24得票数 0
回答已采纳
1回答
我有一个外部的未来操作，我可以覆盖它的onOperation完整方法。我想把它包装起来，最后完成一个承诺。然而，我无法在其他未来完成那个未来。例如：
import scala.concurrent.{Future, Promise}
import scala.util.{Failure, Success}
import scala.concurrent.ExecutionContext.Implicits.global
def foo():Future[String] = {
val p = Promise[String]()
channel.addListener(new Chann
浏览 2提问于2016-09-20得票数 0
回答已采纳
对于Scala和akka，我都是新手，我正在尝试发布端点。发生以下编译错误。
found: akka.http.scaladsl.server.StandardRoute
[error] required: scala.util.Try[Option[com.activegrid.entities.AuthSettings]] => (akka.http.scaladsl.server.RequestContext => scala.concurrent.Future[akka.http.scaladsl.server.RouteResult])
Case类
case cla
浏览 5提问于2016-09-27得票数 0
回答已采纳
我有以下Scala代码，与Scala2.10一起使用
package reactive
import scala.concurrent.future
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.Future
object futuresum extends App {
def f1 = future { 12 }
def f2 = future { 13 }
val result1 = f1.flatMap(x => f2.map(y => x
浏览 2提问于2014-04-20得票数 0
回答已采纳
函数体是否在调用后传递给Future.onComplete()，以及它们的闭包、丢弃和垃圾收集？
我之所以这样问，是因为我正在编写一个无界的Future实例序列。每个Future都有一个.onComplete { case Failure(t)...}，该.onComplete { case Failure(t)...}引用上一个Future的前一个已知的好值。我想避免的是，由于闭包体中的引用，所有Future结果都保存在JVM的内存中。
也许Scala比这更聪明，但是浏览与执行上下文和未来相关的代码并没有产生多大的效果。
谢谢。
浏览 1提问于2019-06-30得票数 3
回答已采纳
用这种方法
def taskA(): Future[Unit] = Future {
Future {
print("Starting nested future")
Thread.sleep(3000)
print("Finished nested future")
}
print("starting outer future")
Thread.sleep(1000)
print("finished outer future")
}
在实际完成外层未来之前，是否有可能等待嵌套的未来完成？我就是这样执行这个程序的：
浏览 0提问于2018-05-14得票数 0
回答已采纳
2回答
我试着理解akka和futures的故障处理。例如，我有父母和孩子的演员。
儿童演员有两个失败案例：
案例1)消息处理过程中发生错误
案例2)错误在未来发生
在这两种情况下，我都需要将错误传播给父级，但是在第二种情况下，没有发生这种情况。我做错什么了？
import akka.actor.SupervisorStrategy.{Decider, Stop}
import akka.actor.{Actor, ActorRef, ActorSystem, OneForOneStrategy, Props, SupervisorStrategy}
import akka.testkit.{Test
浏览 5提问于2017-07-25得票数 1
回答已采纳
1回答
在下面的例子中，预期的行为是什么？
import scala.concurrent.ExecutionContext.Implicits.global
val someFuture = Future { 1+1 }.map(elem => {
println("mapping immediately")
elem.toString
})
someFuture.onComplete {
case scala.util.Success(value) => println(s"Got the callback = $value")
cas
浏览 4提问于2017-06-16得票数 2
回答已采纳
1回答
我对Scala非常陌生，我正在尝试从Play中访问Instagram API！还有斯卡拉。
def authenticate = Action {
request =>
request.getQueryString("code").map {
code =>
WS.url("https://api.instagram.com/oauth/access_token")
.post(
Map("client_id" -> Seq(KEY.key), "client_se
浏览 5提问于2013-11-27得票数 2
回答已采纳
问题
这是scala.concurrent.Future的摘录
def firstCompletedOf[T](futures: TraversableOnce[Future[T]])(implicit executor: ExecutionContext): Future[T] = {
val p = Promise[T]()
val completeFirst: Try[T] => Unit = p tryComplete _
futures foreach { _ onComplete completeFirst }
p.future
}
我
浏览 2提问于2016-12-13得票数 4
回答已采纳
3回答
package p1
import scala.util.Failure
import scala.util.Success
import scala.concurrent.Await
import scala.concurrent.Future
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent.duration._
object modCheck extends App {
def getStudentRoolNo(name: String) = Future {
浏览 4提问于2016-10-07得票数 1
回答已采纳
我正在用Scala编写一个剧本2.3应用程序。我使用mongoDB数据库和ReactiveMongo驱动程序。我调用的读取/写入/更新db中日期的方法返回一个Future[OptionT]。我的问题是:如果我有一种方法首先更新文档，然后读取更新后的文档，那么我需要一个onComplete语句吗？例如：
def updatePasswordInfo(user: LoginUser,info: PasswordInfo): scala.concurrent.Future[Option[BasicProfile]] = {
import LoginUser.passwordInfoForma
浏览 4提问于2014-09-24得票数 0
回答已采纳
6回答
我希望像下面这样的代码会等待这两个未来，但它没有。
object Fiddle {
val f1 = Future {
throw new Throwable("baaa") // emulating a future that bumped into an exception
}
val f2 = Future {
Thread.sleep(3000L) // emulating a future that takes a bit longer to complete
2
}
val lf = List(f1, f2) // i
浏览 4提问于2015-03-30得票数 38
回答已采纳
因此，我正在尝试编写一个任务，直到您告诉它停止为止，它一直在运行：
import scala.concurrent.Future
import scala.concurrent.ExecutionContext
import java.util.concurrent.RejectedExecutionException
def runUntilShutdown(f: => Unit) = {
val ctx = ExecutionContext.fromExecutorService(null)
import ExecutionContext.global
def runT
浏览 1提问于2018-12-06得票数 2
回答已采纳
我正在编写scala <->用于期货的java互操作包装器，我不知道实现scala.concurrent.Future.onComplete ()的正确方法。这可能会奏效：
def onComplete[U](func: Try[T] => U)(implicit executor: ExecutionContext): Unit = {
executor.execute(new Runnable {
@tailrec
def run = value match {
case Some(t) => func(t)
case N
浏览 0提问于2013-08-21得票数 1
回答已采纳
我正在学习scala期货，我已经回答了我的问题。我有一个很简单的例子
import scala.concurrent.ExecutionContext.Implicits.global
import scala.concurrent._
import scala.util.{Failure, Success}
/**
* Created by dummy on 05/02/15.
*/
object FutureUtils extends App{
val f = Future {
Thread.sleep(1000)
println("I am learni
浏览 3提问于2015-02-05得票数 2
回答已采纳
使用来自的稍微修改的示例代码
val sleeptime = 1000
我用val替换了固定常量。
使用2.13.8，程序按预期执行
$ scala FuturesExample3
1 - starting calculation ...
2- before onComplete
A ...
B ...
Got the callback, meaning = 42
C ...
D ...
E ...
F ...
但是如果在scala 3.1.2中编译和执行：
$ scala FuturesExample3
1 - starting calculation ...
2- before onCo
浏览 17提问于2022-07-13得票数 0
2回答
我正在调用一个返回Future of Scala的应用程序接口，我想转换成Reactor Flux，显然没有阻塞，并等待未来的响应。我正在尝试使用EmitterProcessor，当未来是成功的时候，它工作得很好，但不幸的是，它不是未来有超时的时候。
下面是代码
private Flux<D> transformFutureToFlux(Future<T> future) {
EmitterProcessor<D> emitterProcessor = EmitterProcessor.create();
future.onComplete(
浏览 6提问于2019-10-02得票数 0
2回答
我刚刚开始学习Scala的Akka库。我遇到了使用Ask模式从Actor获取响应的情况(就像启动线程来完成一些计算并得到结果一样)。
下面是我的代码，其中我使用了Ask模式，其中的超时阻止了它的执行。为什么？
import akka.actor._
import akka.routing._
import akka.util.Timeout
import akka.pattern.ask
import java.math.BigInteger
import java.time.LocalDate
import scala.concurrent.duration._
import scala.c
浏览 0提问于2015-01-03得票数 1
1回答
我试图围绕异步方法构建我的应用程序，所以我在Scala中使用了未来。有关更多信息，请使用查询Elasticsearch服务器。
我从这个模式开始，所以我首先创建了这个方法：
def insert(person: Person) = {
client.execute {
index into "index" / "type" source person
} onComplete {
case Success(s) => {
logger.info("{} has be
浏览 3提问于2015-08-23得票数 3
回答已采纳
3回答
在Scala中，未来可能会失败，这可以异步地找到：
f onComplete {
case Success(_) => println("Great!")
case Failure(t) => println("An error has occurred: " + t.getMessage)
}
你会如何把这个“翻译”成“Clojure”？我的阅读让我相信Clojure的未来/承诺模型不如Scala的强大，而且您不能像这样捕捉失败。那该怎么办呢？
一个Scala未来永远不需要被问到它的价值--当它准备好的时候，它会告诉你发生了什么(包括它是否
浏览 3提问于2015-08-05得票数 2
回答已采纳
1回答
我正在使用以下代码学习Scala未来：
object DangerousAndSlowService {
def queryNextNumber: Long = {
50
}
}
val number1F = Future { DangerousAndSlowService.queryNextNumber }
number1F.onComplete({
case Success(value) => {
println(s"Got the callback, meaning = $value")
}
浏览 0提问于2018-04-06得票数 0
回答已采纳
这里是Akka 。我的课：
class SomeActor extends UntypedActor {
// ...
}
class SomeMessage {
// ...
}
// Inside onReceive method for another actor:
Future<Fizz> fizzFut = Patterns.ask(someActor, someMsg, 500)
fizzFut.onComplete(new FizzHandler())
class FizzHandler extends akka.dispatch.OnCompl
浏览 3提问于2015-08-23得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
