parallel:并行生产线

平行 并行处理线。 该软件包有助于提高命令行应用程序的性能，这些应用程序可以转换数据以及以面向行的方式读取数据。 注意：输入行的顺序不会保留在输出中。 主要类型是 ，它从读取，将一个函数应用于每个输入行（默认情况下用换行符分隔）并将结果写入 。 采用字节片，因此不采用任何特定格式，因此输入可以是普通行，CSV，换行分隔的JSON或类似的面向行的格式。 输出仅为字节，并且可以再次采用任何格式。 一个不执行任何操作的简单转换的示例： func Noop ( b [] byte ) ([] byte , error ) { return b , nil } 我们可以将此功能连接到IO并使其运行： p := parallel . NewProcessor ( os . Stdin , os . Stdout , Noop ) if err := p . Run (); err