问题
我想使用 zip 来解析（可能）不同长度的两个生成器：

1. for el1, el2 in zip(gen1, gen2):
   
2.     print(el1, el2)

复制代码

但是，如果 gen2 的元素较少，它将“消耗”元素。一个额外的 gen1 元素。

例如，

1. def my_gen(n:int):
   
2.     for i in range(n):
   
3.         yield i
   
4. 
   
5. gen1 = my_gen(10)
   
6. gen2 = my_gen(8)
   
7. 
   
8. list(zip(gen1, gen2))  # Last tuple is (7, 7)
   
9. print(next(gen1))  # printed value is "9" => 8 is missing
   
10. 
    
11. gen1 = my_gen(8)
    
12. gen2 = my_gen(10)
    
13. 
    
14. list(zip(gen1, gen2))  # Last tuple is (7, 7)
    
15. print(next(gen2))  # printed value is "8" => OK

复制代码

显然，缺少一个值（在我之前的示例中为 8 ），因为它在意识到 gen1 没有更多元素之前已被读取（因此产生值 8 ）。但是这个价值在宇宙中消失了。不存在这样的“问题”。当 gen2 是“更长”时。

问题：有没有办法检索这个缺失值（即前面示例中的 gen2）？

注意：我目前正在使用 8 以另一种方式实现它，但我真的很想知道如何获得这个值。

回答
一种方法是实现一个允许您缓存最后一个值的生成器：

1. class cache_last(collections.abc.Iterator):
   
2.     """
   
3.     Wraps an iterable in an iterator that can retrieve the last value.
   
4. 
   
5.     .. attribute:: obj
   
6. 
   
7.        A reference to the wrapped iterable. Provided for convenience
   
8.        of one-line initializations.
   
9.     """
   
10.     def __init__(self, iterable):
    
11.         self.obj = iterable
    
12.         self._iter = iter(iterable)
    
13.         self._sentinel = object()
    
14. 
    
15.     @property
    
16.     def last(self):
    
17.         """
    
18.         The last object yielded by the wrapped iterator.
    
19. 
    
20.         Uninitialized iterators raise a `ValueError`. Exhausted
    
21.         iterators raise a `StopIteration`.
    
22.         """
    
23.         if self.exhausted:
    
24.             raise StopIteration
    
25.         return self._last
    
26. 
    
27.     @property
    
28.     def exhausted(self):
    
29.         """
    
30.         `True` if there are no more elements in the iterator.
    
31.         Violates EAFP, but convenient way to check if `last` is valid.
    
32.         Raise a `ValueError` if the iterator is not yet started.
    
33.         """
    
34.         if not hasattr(self, '_last'):
    
35.             raise ValueError('Not started!')
    
36.         return self._last is self._sentinel
    
37. 
    
38.     def __next__(self):
    
39.         """
    
40.         Retrieve, record, and return the next value of the iteration.
    
41.         """
    
42.         try:
    
43.             self._last = next(self._iter)
    
44.         except StopIteration:
    
45.             self._last = self._sentinel
    
46.             raise
    
47.         # An alternative that has fewer lines of code, but checks
    
48.         # for the return value one extra time, and loses the underlying
    
49.         # StopIteration:
    
50.         #self._last = next(self._iter, self._sentinel)
    
51.         #if self._last is self._sentinel:
    
52.         #    raise StopIteration
    
53.         return self._last
    
54. 
    
55.     def __iter__(self):
    
56.         """
    
57.         This object is already an iterator.
    
58.         """
    
59.         return self
    

复制代码

要使用此选项，请将输入包装到 zip 中：

1. gen1 = cache_last(range(10))
   
2. gen2 = iter(range(8))
   
3. list(zip(gen1, gen2))
   
4. print(gen1.last)
   
5. print(next(gen1))

复制代码

重要的是让 gen2 成为一个迭代器而不是一个可迭代的，这样你就可以知道哪个已经用完了。如果 gen2 用尽，则无需检查 gen1.last 。

另一种方法是重写 zip 以接受可变的迭代序列而不是单个迭代。这将允许您用包含“peek”的链接版本替换可迭代对象。物品：

1. def myzip(iterables):
   
2.     iterators = [iter(it) for it in iterables]
   
3.     while True:
   
4.         items = []
   
5.         for it in iterators:
   
6.             try:
   
7.                 items.append(next(it))
   
8.             except StopIteration:
   
9.                 for i, peeked in enumerate(items):
   
10.                     iterables[i] = itertools.chain([peeked], iterators[i])
    
11.                 return
    
12.             else:
    
13.                 yield tuple(items)
    
14. 
    
15. gens = [range(10), range(8)]
    
16. list(myzip(gens))
    
17. print(next(gens[0]))

复制代码

这种方法有很多问题。它不仅会丢失原始的可迭代对象，还会丢失原始对象可能通过将其替换为链对象而具有的任何有用属性。

问题
我想使用 zip 来解析（可能）不同长度的两个生成器：

1. for el1, el2 in zip(gen1, gen2):
   
2.     print(el1, el2)

复制代码

但是，如果 gen2 的元素较少，它将“消耗”元素。一个额外的 gen1 元素。

例如，

1. def my_gen(n:int):
   
2.     for i in range(n):
   
3.         yield i
   
4. 
   
5. gen1 = my_gen(10)
   
6. gen2 = my_gen(8)
   
7. 
   
8. list(zip(gen1, gen2))  # Last tuple is (7, 7)
   
9. print(next(gen1))  # printed value is "9" => 8 is missing
   
10. 
    
11. gen1 = my_gen(8)
    
12. gen2 = my_gen(10)
    
13. 
    
14. list(zip(gen1, gen2))  # Last tuple is (7, 7)
    
15. print(next(gen2))  # printed value is "8" => OK

复制代码

显然，缺少一个值（在我之前的示例中为 8 ），因为它在意识到 gen1 没有更多元素之前已被读取（因此产生值 8 ）。但是这个价值在宇宙中消失了。不存在这样的“问题”。当 gen2 是“更长”时。

问题：有没有办法检索这个缺失值（即前面示例中的 gen2）？

注意：我目前正在使用 8 以另一种方式实现它，但我真的很想知道如何获得这个值。

回答
一种方法是实现一个允许您缓存最后一个值的生成器：

1. class cache_last(collections.abc.Iterator):
   
2.     """
   
3.     Wraps an iterable in an iterator that can retrieve the last value.
   
4. 
   
5.     .. attribute:: obj
   
6. 
   
7.        A reference to the wrapped iterable. Provided for convenience
   
8.        of one-line initializations.
   
9.     """
   
10.     def __init__(self, iterable):
    
11.         self.obj = iterable
    
12.         self._iter = iter(iterable)
    
13.         self._sentinel = object()
    
14. 
    
15.     @property
    
16.     def last(self):
    
17.         """
    
18.         The last object yielded by the wrapped iterator.
    
19. 
    
20.         Uninitialized iterators raise a `ValueError`. Exhausted
    
21.         iterators raise a `StopIteration`.
    
22.         """
    
23.         if self.exhausted:
    
24.             raise StopIteration
    
25.         return self._last
    
26. 
    
27.     @property
    
28.     def exhausted(self):
    
29.         """
    
30.         `True` if there are no more elements in the iterator.
    
31.         Violates EAFP, but convenient way to check if `last` is valid.
    
32.         Raise a `ValueError` if the iterator is not yet started.
    
33.         """
    
34.         if not hasattr(self, '_last'):
    
35.             raise ValueError('Not started!')
    
36.         return self._last is self._sentinel
    
37. 
    
38.     def __next__(self):
    
39.         """
    
40.         Retrieve, record, and return the next value of the iteration.
    
41.         """
    
42.         try:
    
43.             self._last = next(self._iter)
    
44.         except StopIteration:
    
45.             self._last = self._sentinel
    
46.             raise
    
47.         # An alternative that has fewer lines of code, but checks
    
48.         # for the return value one extra time, and loses the underlying
    
49.         # StopIteration:
    
50.         #self._last = next(self._iter, self._sentinel)
    
51.         #if self._last is self._sentinel:
    
52.         #    raise StopIteration
    
53.         return self._last
    
54. 
    
55.     def __iter__(self):
    
56.         """
    
57.         This object is already an iterator.
    
58.         """
    
59.         return self
    

复制代码

要使用此选项，请将输入包装到 zip 中：

1. gen1 = cache_last(range(10))
   
2. gen2 = iter(range(8))
   
3. list(zip(gen1, gen2))
   
4. print(gen1.last)
   
5. print(next(gen1))

复制代码

重要的是让 gen2 成为一个迭代器而不是一个可迭代的，这样你就可以知道哪个已经用完了。如果 gen2 用尽，则无需检查 gen1.last 。

另一种方法是重写 zip 以接受可变的迭代序列而不是单个迭代。这将允许您用包含“peek”的链接版本替换可迭代对象。物品：

1. def myzip(iterables):
   
2.     iterators = [iter(it) for it in iterables]
   
3.     while True:
   
4.         items = []
   
5.         for it in iterators:
   
6.             try:
   
7.                 items.append(next(it))
   
8.             except StopIteration:
   
9.                 for i, peeked in enumerate(items):
   
10.                     iterables[i] = itertools.chain([peeked], iterators[i])
    
11.                 return
    
12.             else:
    
13.                 yield tuple(items)
    
14. 
    
15. gens = [range(10), range(8)]
    
16. list(myzip(gens))
    
17. print(next(gens[0]))

复制代码

这种方法有很多问题。它不仅会丢失原始的可迭代对象，还会丢失原始对象可能通过将其替换为链对象而具有的任何有用属性。