并行子壳进行工作和报告状态

Question

我正在尝试并行在所有子文件夹中进行工作，并在 bash 中完成每个文件夹的状态。

假设我有一个 work 函数，它可以返回几个状态，

#param #1 is the folder
# can return 1 on fail, 2 on sucess, 3 on nothing happend
work(){
cd $1
// some update thing
return 1, 2, 3
}

现在我在包装器函数中调用此状态

do_work(){

  while read -r folder; do
    tput cup "${row}" 20
    echo -n "${folder}"
    (
      ret=$(work "${folder}")
      tput cup "${row}" 0
      [[ $ret -eq 1 ]] && echo " \e[0;31mupdate failed      \uf00d\e[0m"
      [[ $ret -eq 2 ]] && echo " \e[0;32mupdated            \uf00c\e[0m"
      [[ $ret -eq 3 ]] && echo " \e[0;32malready up to date \uf00c\e[0m"
    ) &>/dev/null
    pids+=("${!}")

    ((++row))
  done < <(find . -maxdepth 1 -mindepth 1 -type d -printf "%f\n" | sort)
  echo "waiting for pids ${pids[*]}"

  wait "${pids[@]}"
}

，并且我想要的是，它每行打印出所有文件夹，并从每个文件中独立更新它们其他并行，当它们完成后，我希望该状态写在该行中。

但是，我不确定子壳是写作的，我需要捕获哪些方式以及依此类推。 我以上的尝试目前尚未正确编写，也不是并行。 如果我可以并行工作，我会得到那些 [1]＆lt; pid＆gt; things和 [1] + 3156389完成... 将我的屏幕弄乱。 如果我将作品本身放在子壳中，那么我没有任何等待。 如果我收集PID，则不会获得响应代码来打印文本以显示状态。

我确实看了 gnu parallalel ，但我认为我不能有这种行为。 （我认为我可以打印完成作业，但我希望打印所有“跑步”作业，并且完成了完成的作业）。

Answer 1

假设/不可思议：

• 为要处理的每个文件夹而产生一个单独的子进程，
• 随着工作进度
• 从子进程进行消息时，将实时显示消息，并将每个孩子的最新消息显示在不同的行中

一般想法是设置一种概要通信的手段（ ic ）...名为管道，普通文件，排队/消息传递系统，插座（通过 bash上的Web搜索获得很多想法Intervocess Communications ）;当父母从系统中读取并发出适当的 tput 命令时，孩子们写信给该系统。

一个非常简单的使用普通文件的示例：

> status.msgs                           # initialize our IC file

child_func () {
    # Usage: child_func <unique_id> <other> ... <args>

    local i

    for ((i=1;i<=10;i++))
    do
        sleep $1

        # each message should include the child's <unique_id> ($1 in this case);
        # parent/monitoring process uses this <unique_id> to control tput output

        echo "$1:message - $1.$i" >> status.msgs
    done
}

clear
( child_func 3 & )
( child_func 5 & )
( child_func 2 & )

while IFS=: read -r child msg
do
    tput cup $child 10
    echo "$msg"
done < <(tail -f status.msgs)

注释：

• （child_func 3＆amp;）构造是消除OS消息RE的一种方法：从Stdout中显示的“背景过程完成”（可能还有其他方法，但目前我正在画一个空白），
• 当使用文件（正常，管道）OP将需要查看锁定方法（ flock flock ？）为了确保来自多个孩子的消息不会互相踩踏，
• op可以通过与父母的 status.msgs 印刷到 status.msgs 的形式。 > 循环
• 假设可变宽度消息OP可能希望在每个打印消息的末尾附加附加 tput el
• 退出循环可能很简单，就像保留发送消息＆lt; id＆gt;：DONDON 的子进程数量的数量，或者跟踪仍在后台运行的儿童数量或。 。

​

                          # no ouput to line #1
  message - 2.10          # messages change from 2.1 to 2.2 to ... to 2.10
  message - 3.10          # messages change from 3.1 to 3.2 to ... to 3.10
                          # no ouput to line #4
  message - 5.10          # messages change from 5.1 to 5.2 to ... to 5.10

​

Answer 2

基于 @markp-fuso的答案：

printer() {
    while IFS=
\t' read -r child msg
    do
        tput cup $child 10
        echo "$child $msg"
    done
}

clear
parallel --lb --tagstring "{%}\t{}" work ::: folder1 folder2 folder3 | printer
echo

Answer 3

您无法控制这样的退出状态。试试看，将您的工作功能重新处理为 echo 状态：

work(){
    cd $1
    # some update thing &> /dev/null without output
    echo "${1}_$status" #status=1, 2, 3
}

而不是从所有文件夹中设置数据收集：

data=$(
    while read -r folder; do
          work  "$folder" &
    done < <(find . -maxdepth 1 -mindepth 1 -type d -printf "%f\n" | sort)
    wait
)

echo "$data"