Update app.py

app.py

@@ -125,8 +125,17 @@ def demucs_separator(audio, checkpoint_name):
 
 # 任务队列和状态存储
 tasks = {}
+running_threads = 0
+condition = threading.Condition()
 
 def process_audio_separation(task_id, mp3_url):
+    global running_threads
+    with condition:
+        while running_threads >= 1:
+            tasks[task_id] = {"status": "queue"}
+            condition.wait()
+        running_threads += 1
+    tasks[task_id] = {"status": "processing"}
     try:
         # 下载MP3文件到本地
         response = requests.get(mp3_url)
@@ -154,6 +163,9 @@ def process_audio_separation(task_id, mp3_url):
             "status": "error",
             "message": str(e)
         }
+    with condition:
+            running_threads -= 1
+            condition.notify_all()
 
 app = Flask(__name__)