Erstellen einer skalierbaren Lösung ohne Futures?

Question

Exploring die HTTP-Client-Binder Feign und ich sehe, dass es does not support Callback-Ergebnisse (DeferredResults). Wie würde ich dann mit der Erstellung eines skalierbaren Endpunkts umgehen, um viele zeitintensive Aufgaben parallel auszuführen? so etwas wie dies versuchen zu vermeiden:

val slowComputation : Future[Array[Bytes] = ??? 

def endpoint = { 
    Await.result(slowComputation(), Duration(1, SECONDS)) 
} 

Answer 1

verstehe ich das richtig: Der ‚def Endpunkt‘ ist eine synchrone Sperrmethode, und Sie können diese Tatsache nicht ändern, da es von einem Rahmen diktiert?

Nun, das heißt, Sie müssen dort blockieren, warten auf die Berechnung/IO zu Ihnen zurückkommen. Das bedeutet auch, dass Sie dort einen Thread verwenden.

Ich denke, das Beste, was Sie tun können, um das Überladen dieses Endpunkts mit vielen wartenden Threads zu verhindern. Also:

• Wie Sie, geben Sie eine Zeitüberschreitung ein.
• Denken Sie darüber nach, wie viele "wartende Threads" Sie akzeptieren möchten. Dann mehr Anfragen abwerfen, wenn zu viele warten. Wie:

val waiting = new AtomicInteger(0) 
val maxThreadsWaiting = 200 

def endpoint() ={ 
    try{ 
     val numberThreadsWaiting = waiting.incrementAndGet() 
     if(numberThreadsWaiting > maxThreadsWaiting) { 
      // Return 'overload' failure. Like HTTP 503 
     } else{ 
      Await.result(slowComputation(), Duration(1, SECONDS)) 
     }  
    } finally { 
     waiting.decrementAndGet() 
    } 
}