Comment puis-je faire Un avenir à l'avenir dans un futur objet?

Env: Akka 2.1, scala version 2.10.M6, JDK 1.7,u5

Est maintenant mon problème:
J'ai: 

future1 = Futures.future(new Callable<Future<object>>(){...});
future2 = ? extends Object;
Future.sequence(future1, future2).onComplete(...)

maintenant en première ligne, j'ai un avenir, de l'Avenir de l'objet, est-il possible de le convertir en un Avenir tout en ne bloquant pas mon thread actuel?

Est-il une méthode en akka? Aussi loin que j'ai vérifié, je havn'pas trouvé encore...
Première fois d'avoir un post....Sry pour le mauvais format et organiser... :~P

  • Ça ne ressemble pas à la Scala. Est-il une raison pour la Scala de balise?
  • En fait, je suis en utilisant akka 2.1 avec scala lib pour 2.10... sry pour la confusion...
InformationsquelleAutor Vincent Zou | 2012-08-08
  1. 40

    Réponse courte (de l'anglais): flatMap dat sh!t

    À réponses courtes (Scala):

    flatMap(identity)

    Plus courte réponse: (Scala 2.12):

    flatten

    Réponse longue (Java):

    flatMap(new Mapper<Future<X>>,Future<X>>() {
  @Override public Future<X> apply(final Future<X> f) { return f; }
})
    • Viktor~~~de Grands fans~~~ et merci pour la solution....flatMap est cool~
    • Heureux hAkking! 🙂
    • : (...pour flatMap, ce que si je le fais à l'intérieur d'Avenir (future1 est appelable funtion) a échoué à l'aide de contrats à Terme.échoué()? le flatMap serait encore appelé? aussi, je ne veux pas le récupérer comme, plus tard je voudrais faire de l'avenir de la séquence de l'échec d'also....By le chemin, je suis à l'aide de java, drôle pour votre anglais de réponse...: )
    • Je ne comprends pas ce que tu veux dire, le plus simple est probablement juste de l'essayer?
    InformationsquelleAutor Viktor Klang
  2. 10

    Remarque: Depuis Viktor Klang's 2012 réponse, il a récemment (Mars 2016) ajouté dans la son blog pour scala 2.12:

    Manquant canonique combinators: aplatir l'

    Êtes-vous l'un de nous Avenir-les utilisateurs qui ont grandi fatigué de la vieille flatMap(identity) standard pour les nations unies-l'imbrication des contrats à Terme comme dans:

    val future: Future[Future[X]] = ???
val flattenedFuture /*: Future[X] */ = future.flatMap(identity)

    Puis j'ai quelques bonnes nouvelles pour vous! En commençant par Scala 2.12

    scala.de façon concomitante.L'avenir aura un aplatissez-la méthode avec la signature suivante:

    def flatten[S](implicit ev: T <:< Future[S]): Future[S]

    Vous permettant d'écrire:

    val future: Future[Future[X]] = ???
val flattenedFuture /*: Future[X] */ = future.flatten
    InformationsquelleAutor VonC
  3. -1

    Vous pouvez créer une autre tâche

    Futures.future(new Runnable(){
     //wait for future1
     //wait for future2
     //do something with the results.
});

    ou de fusionner les tâches

    Futures.future(new Runnable(){
     //do the work future2 would have done.
     //wait for future1
     //do something with the results.
});
    • Merci pour la réponse....mais pourquoi devrions-nous pris la peine d'utiliser avenir lorsque j'essaye de faire tous les trucs async et de dire, let'em être exécutée dans un thread??
    • Il sera toujours exécuté dans plusieurs threads (en supposant que vous avez un bassin de plus d'un thread) comme elle le fait maintenant. Cela ne changera pas le niveau de la concurrence. Si vous avez une piscine de l'un, vous pouvez simplement utiliser l'une tâche pour tout et il pourrait être beaucoup plus simple.
    • oui, il fonctionne bien, mais si future1 est quelque chose de ,disons, que le problème est dans la question de l'après, comme l'Avenir<Avenir<...>>, et ce thread principal serait le blocage de ces longtemps, ce qui serait une perte de temps...et flatMap ferait un nouvel Avenir pour l'Avenir<Avenir<...>> et donner de l'appel vers le thread d'origine qui permettrait d'économiser plus de ressources...Mais merci pour votre suggestion de toute façon. : )
    • Les déchets est relativement simple et, avec une autre approche que l'on pourrait déchets beaucoup plus à mon humble avis. Aussi, vous n'avez pas besoin de continuer à enrouler le Futur des objets. Il n'y a aucune raison pour que cela ne serait pas une plaine avenir. En fait, vous pouvez ajouter tout ce qu'elle fait dans cette tâche, donc il n'y a pas besoin de retourner quoi que ce soit.
    InformationsquelleAutor Peter Lawrey