From b609731fe9566f7c10f369941dd91d1cf283e6e6 Mon Sep 17 00:00:00 2001
From: pyama <pyama@pepabo.com>
Date: Thu, 18 Jul 2024 10:21:54 +0900
Subject: [PATCH] =?UTF-8?q?=E3=82=B8=E3=83=A7=E3=83=96=E3=82=92=E3=81=A9?=
 =?UTF-8?q?=E3=82=93=E3=81=A9=E3=82=93=E3=81=84=E3=82=8C=E3=82=8B?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 build.sh | 67 +++++++++++++++++++++++++++++++++++++++++++-------------
 1 file changed, 52 insertions(+), 15 deletions(-)

diff --git a/build.sh b/build.sh
index 80375eb..356f2bb 100755
--- a/build.sh
+++ b/build.sh
@@ -4,23 +4,60 @@
 CONCURRENT_LIMIT=4
 
 # サービス名の配列を取得
-services_list=($(docker-compose config --services))
+services=($(docker-compose config --services))
 
-# 各サービスをCONCURRENT_LIMITの数に応じて起動する
-index=0
-while [ $index -lt ${#services_list[@]} ]; do
-  # 現在のバッチで起動するサービスのリストを生成
-  services_to_start=()
-  for ((i = 0; i < CONCURRENT_LIMIT && index+i < ${#services_list[@]}; i++)); do
-    services_to_start+=(${services_list[index+i]})
-  done
+# 各サービスをビルドする（省略可能）
+for service in "${services[@]}"; do
+    docker-compose build "$service"
+done
+
+# 起動ジョブの制御用関連変数の初期化
+declare -A pids
+declare -A services_started
+
+# サービスを起動する関数
+start_service() {
+    local service="$1"
+    echo "Starting service: $service"
+    docker-compose up "$service" &
+    pids[$!]=$service
+    services_started[$service]=1
+}
 
-  echo "Starting services: ${services_to_start[*]}"
+# ジョブが終了したか監視し、終わっていれば別のサービスを起動する関数
+watch_jobs() {
+    while [ ${#pids[@]} -ge $CONCURRENT_LIMIT ]; do
+        for pid in "${!pids[@]}"; do
+            if ! kill -0 "$pid" 2>/dev/null; then
+                # ジョブが存在しない場合
+                local finished_service=${pids[$pid]}
+                echo "Service $finished_service finished"
+                unset pids[$pid]
+                return 0
+            fi
+        done
+        # 全てのジョブが実行中の場合、短いスリープ後に再確認
+        sleep 1
+    done
 
-  # サービスを起動
-  docker-compose build ${services_to_start[@]}
-  docker-compose up ${services_to_start[@]}
+    return 1
+}
 
-  # 次のバッチのためのインデックス更新
-  index=$((index + CONCURRENT_LIMIT))
+# サービスを起動する
+for service in "${services[@]}"; do
+    # 既に起動されているかチェック
+    if [[ ! ${services_started[$service]} ]]; then
+        # 現在実行しているジョブの数がCONCURRENT_LIMIT未満時、またはジョブの終了を検出したときに新しいサービスを起動
+        if [[ ${#pids[@]} -lt $CONCURRENT_LIMIT ]] || watch_jobs; then
+            start_service "$service"
+        fi
+    fi
 done
+
+# 全てのジョブが終了するまで待機
+for pid in "${!pids[@]}"; do
+    wait "$pid"
+    echo "Service ${pids[$pid]} finished"
+done
+
+echo "All services have been started."