Clojure-Futures verstehen

Question

Ich versuche Clojure-Futures zu verstehen, und ich habe Beispiele aus den gängigen Clojure-Büchern gesehen, und es gibt Beispiele, in denen Futures für parallele Berechnungen verwendet werden (was sinnvoll erscheint).

Ich hoffe jedoch, dass jemand das Verhalten eines einfachen Beispiels erklären kann, das aus O'Reillys Programmier-Clojure-Buch stammt.

(def long-calculation (future (apply + (range 1e8)))) 

Wenn ich versuche, dies zu dereferenzieren, von

tun

(time @long-calculation) 

Es gibt das richtige Ergebnis (4999999950000000), aber fast sofort (in 0.045 msec) auf meinem Rechner.

Aber wenn ich die eigentliche Funktion aufrufen, wie so

(time (apply + (range 1e8))) 

bekomme ich das auch richtige Ergebnis, aber die benötigte Zeit ist viel größer (~ 5000 msec).

Wenn ich die Zukunft dereferenziere, ist mein Verständnis, dass ein neuer Thread erstellt wird, auf dem der Ausdruck ausgewertet wird - in diesem Fall würde ich erwarten, dass es auch etwa 5000 ms dauert.

Wie kommt die dereferenzierte Zukunft so schnell zum richtigen Ergebnis?

Answer 1

Die Berechnung in einer Zukunft beginnt, sobald Sie die Zukunft erstellen (in einem separaten Thread). In Ihrem Fall, beginnt die Berechnung, sobald Sie (def long-calculation ....)

Dereferenzieren eines von zwei Dingen tun ausführen:

• Wenn die Zukunft noch nicht abgeschlossen hat, Block, bis er abgeschlossen ist und dann wieder den Wert (dies könnte nehmen Sie eine willkürliche Menge von Zeit, oder beenden Sie nie, wenn die Zukunft nicht beendet wird)
• Wenn die Zukunft abgeschlossen ist, geben Sie das Ergebnis zurück. Dies ist fast augenblicklich (weshalb Sie sehr schnell dereferenzieren kehrt zu sehen)

Sie den Effekt durch den Vergleich der folgenden sehen:

;; dereference before future completes 
(let [f (future (Thread/sleep 1000))] 
    (time @f)) 
=> "Elapsed time: 999.46176 msecs" 

;; dereference after future completes 
(let [f (future (Thread/sleep 1000))] 
    (Thread/sleep 2000) 
    (time @f)) 
=> "Elapsed time: 0.039598 msecs"