預設的情況下，Shell指令碼中的命令是序列執行的，必須等到前一條命令執行完後才執行接下來的命令，但是如果我有一大批的的命令需要執行，而且互相又沒有影響的情況下（有影響的話就比較複雜了），那麼就要使用命令的併發執行了。

如下：

#!/bin/bash
IPLIST=/home/meta/ipinfo/iplist
for i in $(cat ${IPLIST} |grep -viE "^#|備機|ts"|awk '{print $1}')
do
    ssh $i "cd ~/update/;tar zxf patch-20160909.tgz -C ~/LMDG/ && echo '/$i
 
 ok' || echo '/$i bad'"
done >> result.txt

echo "resutl"|mutt -a result.txt -s update-result [email protected]126.com

對於上面的程式碼，因為 iplist 中有好多ip，每個”tar zxf”都挺耗時的，所以打算使用併發程式設計，這樣就可以節省大量時間了。

修改如下：

#!/bin/bash
IPLIST=/home/meta/ipinfo/iplist
for i in $(cat ${IPLIST} |grep -viE "^#|備機|ts"|awk '{print $1}'
 
)
do
    ssh $i "cd ~/update/;tar zxf patch-20160909.tgz -C ~/LMDG/ && echo '/$i ok' || echo '/$i bad'" &
done >> result.txt

echo "resutl"|mutt -a result.txt -s update-result [email protected]126.com

加上“&” 之後 “tar zxf”就可以並行執行了。 實質是將”tar zxf” 作為後臺程序在執行，這樣該命令就不會佔用當前bash，其他命令也不用等待前面命令執行完再繼續了，而且可以放入多個任務到後臺，這樣就實現了多工併發。

我本來目的是讓”tar zxf”這個迴圈都執行結束後，再“mutt”前面的結果。如果像上面這樣寫的話，在”tar zxf”都還沒結束時就已經開始執行“mutt”了，得到了錯誤的結果，因此需要做如下修改：

#!/bin/bash
IPLIST=/home/meta/ipinfo/iplist
for i in $(cat ${IPLIST} |grep -viE "^#|備機|ts"|awk '{print $1}')
do
    ssh $i "cd ~/update/;tar zxf patch-20160909.tgz -C ~/LMDG/ && echo '/$i ok' || echo '/$i bad'" &
done >> result.txt
wait
echo "resutl"|mutt -a result.txt -s update-result [email protected]126.com

這裡添加了“wait” 之後就可以達到我們預期的效果了，wait的作用就是等待子任務都執行完之後在結束父任務，繼而執行下面的任務。

但是，緊接著又有問題了，如果這個iplist中的量巨大，這樣一口氣都放到後臺，系統超出負載後，會有效能變差或者宕機風險，因此我們需要一個控制併發數的機制。
因此我們引入了任務佇列的概念，有點類似之前socket舉例中的消費者生產者模型，通過訊息佇列來調節供需的不平衡
修改如下：

#!/bin/bash

IPLIST=/home/meta/ipinfo/iplist #任務（消費者）
THREAD=50                       #宣告併發執行緒併發個數，這個是此應用的關鍵，也就是設定管道的最大任務數
TMPFIFO=/tmp/$$.fifo			#宣告管道名稱，'$$'表示腳本當前執行的程序PID
mkfifo $TMPFIFO                #建立管道
exec 5<>${TMPFIFO}             #建立檔案標示符“5”，這個數字可以為除“0”、“1”、“2”之外的所有未宣告過的字元，以讀寫模式操作管道檔案；系統呼叫exec是以新的程序去代替原來的程序，但程序的PID保持不變，換句話說就是在呼叫程序內部執行一個可執行檔案
rm -rf ${TMPFIFO}              #清除建立的管道檔案

#為併發執行緒建立同樣個數的佔位
for((i=1;i<=$THREAD;i++))
do
   echo ;               
 #借用read命令一次讀取一行的特性，使用一個echo預設輸出一個換行符，來確保每一行只有一個執行緒佔位；這裡讓人聯想到生產者&消費者模型，管道檔案充當訊息佇列，來記錄消費者的需求，然後由生產者去領任務，並完成任務，這裡運用了非同步解耦的思想。
done >&5                
 #將佔位資訊寫入管道

for i in $(cat ${IPLIST} |grep -viE "^#|備機|ts"|awk '{print $1}') #從任務佇列中依次讀取任務
do
        read -u5        
 #從檔案描述符管道中，獲取一個管道的執行緒佔位然後開始執行操作；read中 -u 後面跟fd，表示從檔案描述符中讀入，該檔案描述符可以是exec新開啟的。
        {
               echo $(cat ~/ipinfo/iplist|grep $i|awk '{print $2}');
               ssh -oConnectTimeout=10 -oConnectionAttempts=3 $i "cd /home/Log/;grep 'MIL' mission_2016-08-03*.log |awk -F, '{if(\$19==1370) print \$0}'|
               awk -F, '{if(\$20==0) print \$0}'>miss_info.txt"
               echo "" >&5  
 #任務執行完後在fd5中寫入一個佔位符，以保證這個執行緒執行完後，執行緒繼續保持佔位，繼而維持管道中永遠是50個執行緒數，&表示該部分命令/任務放入後臺不佔當前的bash，實現並行處理
        } &
done
wait                #等待父程序的子程序都執行結束後再結束父程序          
exec 5>&-           #關閉fd5的管道
exit 0