shell 并发脚本 fifo fd6

#!/bin/bash   #声明
 
uptime   #输出开始时间
echo "">url.log  #清空日志
 
limit=$2  #获取进程数量
 
tmp_fifofile="/tmp/$$.fifo" #以pid为文件名
mkfifo $tmp_fifofile  #创建fifo文件
exec 6<>$tmp_fifofile  #定义文件描述符6指向这个fifo管道文件
rm $tmp_fifofile #关联fifo文件和fd6
 
#输出进程数量的回车到fd6
for ((i=0;i<$limit;i++));do
          echo 
     done >&6      
 
#从while管道里读取
cat $1 | while read line  #获取文件($1)的行数,将每一行的内容赋值给line变量
          do
          read -u6  #read -u6命令执行一次,相当于尝试从fd6中获取一行,如果获取不到,则阻塞
          #相当于去获取子shell
{
           echo "$line" >>url.log 2>&1;  #执行命令,line是cat $1的第x行的内容
          sleep 3  #等待3秒
          wait  #等待进程结束
          echo >&6 #完成后再补充一个回车到fd6中,释放一个锁
          # 当进程结束以后,再向fd6中加上一个回车符,即补上了read -u6减去的那个
}&
done
wait
exec 6>&-  #关闭fd6
uptime   #输出结束时间
exit 0

 

执行效果如下:

分别是进程数量是1和5的执行时间,以及结果顺序的一致

图片[1]-shell 并发脚本 fifo fd6-百分数

图片[2]-shell 并发脚本 fifo fd6-百分数

 

图片[3]-shell 并发脚本 fifo fd6-百分数

 

 

图片[4]-shell 并发脚本 fifo fd6-百分数

 

流程:
创建关联fifo文件,循环进程数量,回车输出到fd6里,代表有几个进程数,进程数输入完了之后,执行文件的每一行(每一行都是单独执行的参数,需要单独的进程去执行),每一行都通过管道符+while传递给当前shell,
read -u6去fd6里获取一个子shell(子进程,因为“循环进程数量”的时候,已经存入了N个子shell),read -u6如果获取不到新的子shell之后,陷入阻塞等待新的子进程
获取到了子shell之后,分出shell去执行业务模块,然后继续循环赋予子shell,子shell执行完了业务逻辑后需要关闭,将结果返回给fd6,fd6是阻塞,后面的执行完了也需要等待前面的执行完了才能输出显示,执行完后进程会消失,所以需要再执行一个 echo >&6,来补充新的进程,保证子进程数量,cat $1|while read line执行完了之后,结束了while循环之后,关闭fd6

 

 

 

© 版权声明
THE END
喜欢就支持一下吧
点赞0
分享
评论 抢沙发