免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 程序设计 › Shell › shell 多线程处理
最近访问板块 发新帖
查看: 1041 | 回复: 0
打印 上一主题 下一主题

[系统管理] shell 多线程处理 [复制链接]

router_id

论坛徽章:
0
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2018-09-07 20:39 |只看该作者 |倒序浏览
大家好！新的问题来麻烦大家！
我在网站看到前辈用shell控制多线程的脚本。在调试过程中遇到死循环的问题。总是把task执行不完。脚本一直到再调用CheckQue函数.成了死循环。请高手指点.

前辈的脚本链接：https://mp.weixin.qq.com/s?__biz ... ua4BcRYdrju9FRKx#rd

测试下来没有达到前辈所说的效果。我测试是前辈文档里面的例2 使用模拟队列来控制进程数量

脚本如下
#!/bin/bash
#set -x
taskNum=15
ProcNum=5
function PushQue(){
        Que="$Que $1"
        Nrun=$(($Nrun+1))
}

function GenQue(){
        OldQue="$Que"
        Que=""
        Nrun=0
        for PID in $OldQue;do
                if [ -d /proc/$PID ];then
                        PushQue $PID
                fi
        done
}

function CheckQue(){
        OldQue="$Que"
        for PID in $OldQue;do
                if [ -d /proc/$PID ];then
                        GenQue;break
                fi
        done
}
for ((i=1;i<=$taskNum;i++));do
        echo "rogress $i is sleeping for 3 seconds zzz....."
        sleep 3 &
        PID=$!
        PushQue $PID
        while [ $Nrun -ge $ProcNum ];do
                CheckQue
                sleep 0.1
        done
done

wait

echo -e "time-consumingSECONDS seconds"


脚本调试过程
[root@hky c]# bash -x duojincheng.sh
+ taskNum=15
+ ProcNum=5
+ (( i=1 ))
+ (( i<=15 ))
+ echo 'Progress 1 is sleeping for 3 seconds zzz.....'
Progress 1 is sleeping for 3 seconds zzz.....
+ PID=32136
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ '[' 1 -ge 5 ']'
+ (( i++ ))
+ (( i<=15 ))
+ sleep 3
+ echo 'Progress 2 is sleeping for 3 seconds zzz.....'
Progress 2 is sleeping for 3 seconds zzz.....
+ PID=32137
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ '[' 2 -ge 5 ']'
+ (( i++ ))
+ (( i<=15 ))
+ echo 'Progress 3 is sleeping for 3 seconds zzz.....'
Progress 3 is sleeping for 3 seconds zzz.....
+ PID=32138
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ '[' 3 -ge 5 ']'
+ (( i++ ))
+ (( i<=15 ))
+ echo 'Progress 4 is sleeping for 3 seconds zzz.....'
Progress 4 is sleeping for 3 seconds zzz.....
+ PID=32139
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ sleep 3
+ '[' 4 -ge 5 ']'
+ (( i++ ))
+ (( i<=15 ))
+ echo 'Progress 5 is sleeping for 3 seconds zzz.....'
Progress 5 is sleeping for 3 seconds zzz.....
+ PID=32140
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
+ sleep 3
+ sleep 3
+ sleep 3
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
+ '[' 5 -ge 5 ']'
+ CheckQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ GenQue
+ OldQue=' 32136 32137 32138 32139 32140'
+ Que=
+ Nrun=0
+ for PID in '$OldQue'
+ '[' -d /proc/32136 ']'
+ PushQue 32136
+ Que=' 32136'
+ Nrun=1
+ for PID in '$OldQue'
+ '[' -d /proc/32137 ']'
+ PushQue 32137
+ Que=' 32136 32137'
+ Nrun=2
+ for PID in '$OldQue'
+ '[' -d /proc/32138 ']'
+ PushQue 32138
+ Que=' 32136 32137 32138'
+ Nrun=3
+ for PID in '$OldQue'
+ '[' -d /proc/32139 ']'
+ PushQue 32139
+ Que=' 32136 32137 32138 32139'
+ Nrun=4
+ for PID in '$OldQue'
+ '[' -d /proc/32140 ']'
+ PushQue 32140
+ Que=' 32136 32137 32138 32139 32140'
+ Nrun=5
+ break
+ sleep 0.1
^C
[root@hky c]#


[root@hsckey c]# ./duojincheng.sh
Progress 1 is sleeping for 3 seconds zzz.....
Progress 2 is sleeping for 3 seconds zzz.....
Progress 3 is sleeping for 3 seconds zzz.....
Progress 4 is sleeping for 3 seconds zzz.....
Progress 5 is sleeping for 3 seconds zzz.....
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP