如何返回矢量？

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