MultiplexerLongest¶
- class torchdata.datapipes.iter.MultiplexerLongest(*datapipes)¶
一次从每个输入 Iterable DataPipes 中生成一个元素(函数名称:
mux_longest
)。也就是说,从第一个输入 DataPipe 中生成一个元素,然后在下一次迭代中从第二个输入 DataPipe 中生成一个元素,依此类推。它会跳过已耗尽的 DataPipes,并在所有输入 DataPipes 都耗尽时结束。- 参数:
datapipes – 将轮流生成其元素的 Iterable DataPipes,直到它们全部耗尽
示例
>>> from torchdata.datapipes.iter import IterableWrapper >>> dp1, dp2, dp3 = IterableWrapper(range(5)), IterableWrapper(range(10, 15)), IterableWrapper(range(20, 25)) >>> list(dp1.mux_longest(dp2, dp3)) [0, 10, 20, 1, 11, 21, 2, 12, 22, 3, 13, 23, 4, 14, 24]