Jakie są zalety Twitter Future w stosunku do Scala Future?

Question

Znam wiele powodów, dla których Scala Future będzie lepsza. Czy są jakieś powody do używania Twitter Future zamiast? Poza tym, że Finagle go używa.

Answer 1

Nota prawna: Pracowałem na Twitterze nad implementacją Future. Trochę kontekstu, rozpoczęliśmy własną implementację, zanim Scala miała "dobrą" implementację Future.

Here're cechy Twittera Future:

• Niektóre nazwy są różne metody i Twittera Future ma kilka nowych metod pomocniczych w towarzysza.

np. Tylko jeden przykład: Future.join(f1, f2) może pracować na heterogenicznych typach Future.

Future.join(
    Future.value(new Object), Future.value(1) 
).map { 
    case (o: Object, i: Int) => println(o, i) 
} 

o i i zachować swoje typy, nie są one odlewane do najmniejszego wspólnego supertypem Any.

• Łańcuch onSuccess gwarantuje realizowane w podanej kolejności: np

  f.onSuccess { 
      println(1) // #1 
  } onSuccess { 
      println(2) // #2 
  } 
  

# 1 jest zagwarantowana jest wykonywane przed # 2

• Model gwintowania jest trochę inny. Nie ma pojęcia Kontekstu Wykonawczego, Wątek, który wyznaczył wartość w Obietnicy (Mutable Implementation of the Future), to ten, który wykonuje wszystkie obliczenia na przyszłym wykresie. np .:

  val f1 = new Promise[Int] 
  f1.map(_ * 2).map(_ + 1) 
  f1.setValue(2) // <- this thread also executes *2 and +1 
  

• Istnieje pojęcie przerwania/odwołania. Dzięki Futures firmy Scala informacje płyną tylko w jednym kierunku, a dzięki Przyszłości Twittera możesz powiadomić producenta o pewnych informacjach (niekoniecznie anulowaniu). W praktyce jest on używany w programie Finagle do propagowania anulowania wywołania RPC. Ponieważ Finagle propaguje również anulowanie w całej sieci i ponieważ Twitter ma ogromną popularność z żądań, to faktycznie oszczędza dużo pracy.

  class MyMessage extends Exception 
  
  val p = new Promise[Int] 
  p.setInterruptHandler { 
      case ex: MyMessage => println("Receive MyMessage") 
  } 
  
  val f = p.map(_ + 1).map(_ * 2) 
  f.raise(new MyMessage) // print "Receive MyMessage" 
  

• Do niedawna Twittera Future były jedynym wdrożyć efektywne ogon rekurencji (czyli można mieć funkcji rekurencyjnej, że nazywają się bez wysadzania zadzwonić stosu). Został zaimplementowany w Scali 2.11+ (jak sądzę).

Answer 2

O ile mogę stwierdzić, że główną różnicą, która mogłaby sprzyjać korzystaniu z Twittera Future, jest to, że można je anulować, w przeciwieństwie do wersji Future firmy scala.

Ponadto, istniało pewne wsparcie dla śledzenia łańcuchów wywołań (jak zapewne wiesz, ślady zwykłego stosu są prawie bezużyteczne w przypadku kontraktów Futures). Innymi słowy, możesz wziąć Future i powiedzieć, który łańcuch wyprodukował go. Ale pomysł został porzucony, jeśli dobrze rozumiem.