在网上进行了一些搜索，找到了使用命名管道的简单“教程”。但是，当我对后台作业执行任何操作时，我似乎会丢失很多数据。

[[编辑：找到了一个简单得多的解决方案，请参阅回复。因此，我提出的问题现在是学术性的，以防万一可能需要工作服务器]]

在Linux 2.6.32-25-generic＃45-Ubuntu SMP上使用Ubuntu 10.04（星期六）10月16日19:52:42 UTC
2010 x86_64 GNU / Linux

GNU bash版本4.1.5（1）-发行版（x86_64-pc-linux-gnu）。

我的bash函数是：

function jqs
{
  pipe=/tmp/__job_control_manager__
  trap "rm -f $pipe; exit"  EXIT SIGKILL

  if [[ ! -p "$pipe" ]]; then
      mkfifo "$pipe"
  fi

  while true
  do
    if read txt <"$pipe"
    then
      echo "$(date +'%Y'): new text is [[$txt]]"

      if [[ "$txt" == 'quit' ]]
      then
    break
      fi
    fi
  done
}

我在后台运行：

> jqs&
[1] 5336

现在我喂它：

for i in 1 2 3 4 5 6 7 8
do
  (echo aaa$i > /tmp/__job_control_manager__ && echo success$i &)
done

输出不一致。我经常没有得到所有成功的回声。我得到的新文本回声与成功回声最多，有时更少。

如果我从“提要”中删除“＆”，它似乎可以工作，但是在读取输出之前，我一直处于阻塞状态。因此，我想让子流程受阻，而不是主流程受阻。

目的是编写一个简单的作业控制脚本，这样我最多可以并行运行10个作业，并将其余的作业排队等待以后的处理，但可靠地知道它们确实可以运行。

完整的职位经理如下：

function jq_manage
{
  export __gn__="$1"

  pipe=/tmp/__job_control_manager_"$__gn__"__
  trap "rm -f $pipe"    EXIT
  trap "break"      SIGKILL

  if [[ ! -p "$pipe" ]]; then
      mkfifo "$pipe"
  fi

  while true
  do
    date
    jobs
    if (($(jobs | egrep "Running.*echo '%#_Group_#%_$__gn__'" | wc -l) < $__jN__))
    then
      echo "Waiting for new job"
      if read new_job <"$pipe"
      then
    echo "new job is [[$new_job]]"

    if [[ "$new_job" == 'quit' ]]
    then
      break
    fi

    echo "In group $__gn__, starting job $new_job"
    eval "(echo '%#_Group_#%_$__gn__' > /dev/null; $new_job) &"
      fi
    else
      sleep 3
    fi
  done
}

function jq
{
  # __gn__ = first parameter to this function, the job group name (the pool within which to allocate __jN__ jobs)
  # __jN__ = second parameter to this function, the maximum of job numbers to run concurrently

  export __gn__="$1"
  shift
  export __jN__="$1"
  shift

  export __jq__=$(jobs | egrep "Running.*echo '%#_GroupQueue_#%_$__gn__'" | wc -l)
  if (($__jq__ '<' 1))
  then
    eval "(echo '%#_GroupQueue_#%_$__gn__' > /dev/null; jq_manage $__gn__) &"
  fi

  pipe=/tmp/__job_control_manager_"$__gn__"__

  echo $@ >$pipe
}

呼唤

jq <name> <max processes> <command>
jq abc 2 sleep 20

将开始一个过程。那部分工作正常。开始第二个，很好。似乎一个接一个地工作正常。但是，像上面更简单的示例一样，以循环开头10似乎会使系统丢失。

我将为解决这种明显的IPC数据丢失问题提供任何建议。

问候，阿兰。