如何返回矢量？

Question

我有一個通道，我將值放入doseq循環中。

此代碼ISBN清單併爲每個ISBN讀取，確實亞馬遜搜索還書的內容，然後調用另一個函數來獲得銜

(def book_channel (chan 10)) 

Answer 1

你需要做一些類型的協調，以確定所有工作完成。你可以拉的協調伸到主線程相當容易：

(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))))))) 

在這裏，我用了一個循環，一直等待結果，並將它們添加到載體，直到我們有儘可能多的結果，因爲我們做的ISBN。你需要確保get_title_and_rank_for_one_isbn總是產生一個可以放在頻道上的結果，否則循環將永遠等待。

Answer 2

確保您使用clojure.core.async/into而不是clojure.core/into。下面是從收集往返於海峽的一個例子，回到集合：

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返回將會有一個確切的項目寫入一個通道。一旦它的輸入通道關閉，將會寫入一個項目。這使整個事物保持異步，它確實需要將代碼放入書通道的代碼關閉該通知，以表示所有書籍都在那裏。

Answer 3

您應該關閉！完成後將book_channel推入其中。每個異步/進入文檔 - 「ch必須先關閉才能生成結果。」

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

或者，你可以使用異步/到瓚將關閉通道爲您提供：

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