如何合并两个python迭代器？

Question

我有两个迭代器，一个list和一个itertools.count对象（即无限值生成器）。我想这两个合并成结果的迭代器，交替两者之间的屈服值：

>>> import itertools 
>>> c = itertools.count(1) 
>>> items = ['foo', 'bar'] 
>>> merged = imerge(items, c) # the mythical "imerge" 
>>> merged.next() 
'foo' 
>>> merged.next() 
1 
>>> merged.next() 
'bar' 
>>> merged.next() 
2 
>>> merged.next() 
Traceback (most recent call last): 
    ... 
StopIteration 

什么是最简单，最简洁的方式做到这一点？

Answer 1

发电机将很好地解决您的问题。

def imerge(a, b): 
    for i, j in itertools.izip(a,b): 
     yield i 
     yield j 

Answer 2

我会做这样的事情。这将是大多数时间和空间的高效率，因为您不会将对象压缩在一起。如果a和b都是无限的，这也将起作用。

def imerge(a, b): 
    i1 = iter(a) 
    i2 = iter(b) 
    while True: 
     try: 
      yield i1.next() 
      yield i2.next() 
     except StopIteration: 
      return 

Answer 3

您可以使用zip以及itertools.chain。这将只有工作如果第一清单有限：

merge=itertools.chain(*[iter(i) for i in zip(['foo', 'bar'], itertools.count(1))]) 

Answer 4

你可以做一些事情，几乎是exaclty什么@Pramod首先提出。

def izipmerge(a, b): 
    for i, j in itertools.izip(a,b): 
    yield i 
    yield j 

这种方法的优点是，如果a和b都是无限的，则不会耗尽内存。

Answer 5

为什么需要itertools？

def imerge(a,b): 
    for i,j in zip(a,b): 
     yield i 
     yield j 

在这种情况下，a或b中的至少一个必须是有限长度，因为zip会返回一个列表，而不是迭代器。如果你需要一个迭代器作为输出，那么你可以去找Claudiu解决方案。

Answer 6

我不确定你的应用程序是什么，但是你可能会发现enumerate（）函数更有用。

>>> items = ['foo', 'bar', 'baz'] 
>>> for i, item in enumerate(items): 
... print item 
... print i 
... 
foo 
0 
bar 
1 
baz 
2 

Answer 7

我也同意itertools是不需要的。

但为什么停在2？

def tmerge(*iterators): 
    for values in zip(*iterators): 
     for value in values: 
     yield value 

可以处理从0开始的任意数量的迭代器。

更新：DOH！一位评论者指出，除非所有迭代器的长度相同，否则这将不起作用。

正确的代码是：

def tmerge(*iterators): 
    empty = {} 
    for values in itertools.izip_longest(*iterators, fillvalue=empty): 
    for value in values: 
     if value is not empty: 
     yield value 

，是的，我刚和不等长的名单试了一下，包含列表{}。

Answer 8

使用itertools.izip（），而不是拉链（）在一些其他的答案，将提高性能：

为“是pydoc itertools.izip”表示：“工程就像拉链（）函数，但通过返回迭代器而不是列表来消耗更少的内存。“

Itertools。即使其中一个迭代器是无限的，izip也可以正常工作。

Answer 9

使用izip和链一起：

>>> list(itertools.chain.from_iterable(itertools.izip(items, c))) # 2.6 only 
['foo', 1, 'bar', 2] 

>>> list(itertools.chain(*itertools.izip(items, c))) 
['foo', 1, 'bar', 2] 

Answer 10

简明的方法是使用一台发电机的表达与itertools.cycle（）。它避免了创建元组的长链（）。

generator = (it.next() for it in itertools.cycle([i1, i2])) 

Answer 11

我宁愿这是更为简洁的这另一种方式：

iter = reduce(lambda x,y: itertools.chain(x,y), iters) 

Answer 12

一个Python中的鲜为人知的特点之一是，你可以有更多的条款在发电机表达。对于展开嵌套列表非常有用，例如从zip（）/ izip（）获取的列表。

def imerge(*iterators): 
    return (value for row in itertools.izip(*iterators) for value in row) 

Answer 13

这里是一个优雅的解决方案：

def alternate(*iterators): 
    while len(iterators) > 0: 
     try: 
      yield next(iterators[0]) 
      # Move this iterator to the back of the queue 
      iterators = iterators[1:] + iterators[:1] 
     except StopIteration: 
      # Remove this iterator from the queue completely 
      iterators = iterators[1:] 

使用实际队列获得更好的性能（由大卫的建议）：

from collections import deque 

def alternate(*iterators): 
    queue = deque(iterators) 
    while len(queue) > 0: 
     iterator = queue.popleft() 
     try: 
      yield next(iterator) 
      queue.append(iterator) 
     except StopIteration: 
      pass 

当一些迭代器是有限的，它的工作原理，甚至其他人是无限的：

from itertools import count 

for n in alternate(count(), iter(range(3)), count(100)): 
    input(n) 

打印：

0 
0 
100 
1 
1 
101 
2 
2 
102 
3 
103 
4 
104 
5 
105 
6 
106 

它也正确停止如果/当所有迭代器已用尽。

如果要处理非迭代iterables，如列表，你可以使用

def alternate(*iterables): 
    queue = deque(map(iter, iterables)) 
    ...