Wie kann ich einen Vektor zurückgeben?

Question

Ich habe einen Kanal, in dem ich Werte in eine doseq-Schleife setze.

Dieser Code aus einer Liste von ISBN-Nummern liest und für jede ISBN-Nummer, funktioniert ein amazon Suche Inhalt eines Buches zurückzukehren, und ruft dann eine andere Funktion, um den Titel und Rang zu erhalten

(def book_channel (chan 10)) 

Answer 1

Sie müssen irgendeine Art von Koordination tun, um zu bestimmen, wann alle Ihre Arbeit beendet ist . Sie können, dass die Koordination ziehen ziemlich leicht in den Haupt-Thread aus:

(def book_channel (chan 10)) 
(defn concurrency_test 
    [list_of_isbns] 
    (doseq [isbn list_of_isbns] 
    (go (>! book_channel 
      (get_title_and_rank_for_one_isbn 
       (amazon_search isbn))))) 
    (prn (loop [results []] 
       (if (= (count results) (count list_of_isbns)) 
        results 
        (recur (conj results (<!! book_channel))))))) 

Hier habe ich eine Schleife verwendet, die für die Ergebnisse immer wieder warten und das Hinzufügen von ihnen zu dem Vektor, bis wir so viele Ergebnisse haben, wie wir ISBN-Nummern zu tun. Sie sollten sicherstellen, dass get_title_and_rank_for_one_isbn immer ein Ergebnis erzeugt, das auf einen Kanal gesetzt werden kann, andernfalls wartet die Schleife für immer.

Answer 2

stellen Sie sicher, Sie verwenden clojure.core.async/into statt clojure.core/into. Hier ist ein Beispiel für eine Hin- und Rückfahrt von der Sammlung zu kanalisieren und zurück zur Kollektion:

user> (require '[clojure.core.async :as async :refer [<! <!! >!! >! chan go]]) 
nil 

user> (def book-chan (async/to-chan [:book1 :book2 :book3])) 
#'user/book-chan 

user> (<!! (clojure.core.async/into [] book-chan)) 
[:book1 :book2 :book3] 

clojure.core.async/into gibt einen Kanal, der genau ein Element, um es geschrieben haben. Dieses eine Element wird geschrieben, sobald der Eingangskanal geschlossen ist. Dies hält die ganze Sache asynchron und es erfordert, dass der Code, der Dinge in den Buchkanal legt, den Chan schließt, um zu signalisieren, dass alle Bücher da sind.

Answer 3

Sie sollten schließen! der book_channel, nachdem du es fertig gemacht hast, etwas hineinzuschieben. Per async/in Dokumentation - "ch muss zuvor schließen, um ein Ergebnis zu erzeugen."

(let [book> (chan)] 
    (go 
    (doseq [e (range 8)] 
     (>! book> e)) 
    (close! book>)) 
    (<!! (async/into [] book>))) 

Alternativ können Sie async/onto-chan benutzen, die den Kanal für Sie schließt:

(let [book> (chan)] 
    (async/onto-chan book> (range 8)) 
    (<!! (async/into [] book>)))