Clojure：在循环另一个集合的同时循环一个集合？

Question

我有两个系列x和y，都有不同数量的项目。我想通过x循环，并做一些副作用，而通过y骑自行车。我不想在通过x循环时重复y。既doseq和for重复y：

(for [x (range 5) 
     y ["A" "B"]] 
    [x y]) 

这产生([0 "A"] [0 "B"] [1 "A"] [1 "B"] [2 "A"] [2 "B"] [3 "A"] [3 "B"] [4 "A"] [4 "B"])。

我想要的是会产生的东西：([0 "A"] [1 "B"] [2 "A"] [3 "B"] [4 "A"])。

背景，我有一个文件行和core.async渠道（比如5），我希望把每行到下一个通道在我的收藏，是这样的：

(defn load-data 
    [file chans] 
    (with-open [rdr (io/reader file)] 
    (go 
     (doseq [l (line-seq rdr) 
       ch chans] 
     (>! ch l))))) 

Answer 1

如果传递到多个序列map它在锁步骤中逐步通过它们中的每一个来调用具有来自每个当前位置的值的映射函数。当其中一个序列用完时停止。

user> (map vector (range 5) (cycle ["A" "B"])) 
([0 "A"] [1 "B"] [2 "A"] [3 "B"] [4 "A"]) 

在这种情况下，从(cycle ["A" "B"])序列将继续生产As和烧烤永远虽然地图会停止食用它们(range 5)结束序列时。每一步然后用这两个参数调用向量函数，并将结果添加到输出序列中。

和第二例使用去环是散开的输入序列的一个相当标准的方法：

user> (require '[clojure.core.async :refer [go go-loop <! <!! >!! >! chan close!]]) 
nil 
user> (defn fanout [channels file-lines] 
     (go-loop [[ch & chans] (cycle channels) 
        [line & lines] file-lines] 
      (if line 
      (do 
       (>! ch line) 
       (recur chans lines)) 
      (doseq [c channels] 
       (close! c))))) 
#'user/fanout 
user> (def lines ["first" "second" "third" "fourth" "fifth"]) 
#'user/lines 
user> (def test-chans [(chan) (chan) (chan)]) 
#'user/test-chans 
user> (fanout test-chans lines) 
#<ManyToManyChannel clojure.core.async.impl.channels.ManyToManyChannel@3b363fc5> 
user> (map <!! test-chans) 
("first" "second" "third") 
user> (map <!! test-chans) 
("fourth" "fifth" nil)