主页 / unix / 问题 / 472117
Accepted
Josh
Asked: 2018-09-29 08:38:44 +0800 CST

如何并行运行多个 pv 命令？

  • 772

pv我想在每个命令管道上运行一系列命令管道。这是一个例子：

for p in 1 2 3
do
  cat /dev/zero | pv -N $p | dd of=/dev/null &
done

管道中的实际命令无关紧要（cat/dd只是一个例子）......

目标是 4 个同时运行的管道，每个管道都有自己的pv输出。但是，当我尝试对这样的命令进行后台处理时，pv停止并且我得到的只是 4 个停止的作业。我试过了{...|pv|...}&，bash -c "...|pv|..." &结果都是一样的。

如何同时运行多个pv命令管道？

shell parallelism

2 个回答

  1. Best Answer

    发现我可以使用xargs以下-P选项执行此操作：

    josh@subdivisions:/# seq 1 10 | xargs -P 4 -I {} bash -c "dd if=/dev/zero bs=1024 count=10000000 | pv -c -N {} | dd of=/dev/null"
        3: 7.35GiB 0:00:29 [ 280MiB/s] [                                                                                         <=>                                                                 ]
        1: 7.88GiB 0:00:29 [ 312MiB/s] [                                                                                         <=>                                                                 ]
        4: 7.83GiB 0:00:29 [ 258MiB/s] [                                                                                         <=>                                                                 ]
        2: 6.55GiB 0:00:29 [ 238MiB/s] [                                                                                         <=>                                                                 ]

    发送数组的输出以迭代到标准输入xargs；要同时运行所有命令，请使用-P 0

    • 7

  2. pv无法在后台启动。

    正如您在源代码的src/main/main.c文件中看到的那样pv，他们在TOSTOP终端上设置标志tcsetattr()（在c.c_lflag结构中termios）。他们这样做是为了SIGTTOU在不在前台时尝试写入终端时接收 a，用信号处理程序捕获它，并将输出重定向到/dev/null，以免“弄乱”终端。

    /*
 * Set terminal option TOSTOP so we get signal SIGTTOU if we try to
 * write to the terminal while backgrounded.
 *
 * Also, save the current terminal attributes for later restoration.
 */
memset(&t, 0, sizeof(t));
tcgetattr(STDERR_FILENO, &t);
t_save = t;
t.c_lflag |= TOSTOP;
tcsetattr(STDERR_FILENO, TCSANOW, &t);

    这当然很糟糕，因为它不仅为自己设置了该标志，还为使用终端的所有程序设置了该标志。

    但这还不是全部。如 glibc手册中所述：

    功能： int tcsetattr (int filedes, int when, const struct termios *termios -p)

    如果从其控制终端上的后台进程调用此函数，通常会向进程组中的所有进程发送一个 SIGTTOU 信号，就像进程试图写入终端一样。例外情况是调用进程本身忽略或阻塞 SIGTTOU 信号，在这种情况下执行操作并且不发送信号。请参阅作业控制。

    他们没有阻止或忽略SIGTTOU. 而且他们也没有检查（如果他们之前设置了信号处理程序tcsetattr()，它将返回 -1 并设置errno为）的返回值。EINTR SIGTTOU

    因此该过程停止。如果它收到一个SIGCONT（来自bg命令），它将在尝试完成时再次停止tcsetattr()。

    所以我想你应该把它当作一个功能;-)

    • 4

相关问题