如何在python + linux中并行侦听端口

Question

所有人！我有一个python脚本，它处理来自COM-port的输入。

import sys
for string in sys.stdin:
    some_calculation(string)

它是这样运行的：

cat -v /dev/pts/2 | python3 'process.py'

我想使它并行，例如，通过使用GNU并行。我的方式是这样的:一个平行的B

cat -v /dev/pts/2 | parallel  --pipe --recstart '>' python3 process.py

但这是行不通的。

有什么想法吗？非常感谢。更新:我找到了一些解决方案：

cat /dev/pts/2 | parallel -j2 "echo {} | python3 process.py"

另一张是伊尼安写的：

cat -v /dev/pts/2 | parallel --recstart '>' --pipe python3 process.py

Answer 1

您可以使用GNU parallel选项调用--pipe，如下所示：

--pipe
        Spread input to jobs on stdin (standard input). Read a block
        of data from stdin (standard input) and give one block of data
        as input to one job.

在restart之前使用--pipe标志

cat -v /dev/pts/2 | parallel --recstart '>' --pipe python3 process.py

更多关于GNU parallel的信息。