ベクターを返すにはどうしたらいいですか？

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/intoではなくclojure.core.async/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正確に一つの項目がそれに書かれていますチャネルを返します。その1つの項目は入力チャンネルが終了すると書き込まれます。これはすべてのことを非同期に保ち、すべての本がそこにあることを知らせるために、コードをブックチャンネルに入れることが必要です。

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