解决Python命令行音乐播放器无法自动切歌的多任务并发控制问题

我明白你的问题啦——现在你的播放器因为卡在等待用户输入的环节，导致歌曲播放完后没法自动跳转到下一首。咱们先拆解下现有代码的核心问题，再给出一个可行的解决方案～

现有代码的问题分析 #

你当前用ThreadPoolExecutor提交了control任务，但在播放循环里调用future.result()会直接阻塞主线程：因为input()是阻塞式操作，哪怕歌曲已经播放完毕（playback.active变为False），主线程还会一直卡在等待用户输入的状态，根本没机会去触发下一首歌的播放。

解决方案思路 #

咱们需要把播放逻辑和用户输入控制逻辑拆成两个完全独立的线程，用一个线程安全的队列来传递控制命令。这样播放线程可以同时监听播放状态和队列里的命令，不会被用户输入阻塞，歌曲播放完就能自动触发切歌。

修改后的完整代码 #

import queue
import threading
import time
# 假设你的Playback类已经正确实现了play/pause/resume/stop/active属性
from your_playback_module import Playback

def control(command_queue):
    """持续监听用户输入，把合法命令放入队列"""
    while True:
        mediactl = input("Control (pause | resume | stop | next | prev): ")
        print("------------------------------------")
        print()
        if mediactl in ("pause", "resume", "stop", "next", "prev"):
            command_queue.put(mediactl)
        else:
            print("无效命令，请输入 pause/resume/stop/next/prev 中的一个")

def play_track(track, command_queue):
    """播放单首曲目，同时监听控制命令和播放状态"""
    print("------------------------------------")
    print(f"Playing Track: | Title: {track['Title']} | Artist: {track['Artist']} | Album: {track['Album']}"
          f" | Date: {track['Date']} | Length: {track['Length']}")
    print("------------------------------------")

    playback = Playback()
    playback.load_file(track["Path"])
    playback.play()

    # 循环监听播放状态和命令队列
    while playback.active:
        try:
            # 非阻塞获取队列中的命令，避免卡死在等待输入上
            mediactl = command_queue.get_nowait()
            match mediactl:
                case "pause":
                    playback.pause()
                    print("Track is paused")
                case "resume":
                    playback.resume()
                    print("Track is resumed")
                case "stop":
                    playback.stop()
                    print("Playback is stopped")
                    return None  # 返回None表示终止整个播放流程
                case "next":
                    playback.stop()
                    print("Next track is playing")
                    return "next"
                case "prev":
                    playback.stop()
                    print("Previous track is playing")
                    return "prev"
        except queue.Empty:
            # 队列空时，继续检查播放状态，不阻塞
            pass
        # 加个小延迟，减少CPU空转消耗
        time.sleep(0.1)
    
    # 曲目自然播放完毕，返回next触发切歌
    print("当前曲目播放完毕，自动切换到下一首")
    return "next"

def main():
    # 示例曲目列表，替换成你自己的曲目数据
    track_list = [
        {"Title": "示例歌曲1", "Artist": "歌手A", "Album": "专辑X", "Date": "2023", "Length": "3:45", "Path": "/path/to/song1.mp3"},
        {"Title": "示例歌曲2", "Artist": "歌手B", "Album": "专辑Y", "Date": "2024", "Length": "4:10", "Path": "/path/to/song2.mp3"},
    ]
    current_track_idx = 0
    # 初始化线程安全队列，用于传递控制命令
    command_queue = queue.Queue()

    # 启动控制线程，设置为守护线程，主线程结束时自动退出
    control_thread = threading.Thread(target=control, args=(command_queue,), daemon=True)
    control_thread.start()

    # 主播放循环
    while current_track_idx >= 0 and current_track_idx < len(track_list):
        result = play_track(track_list[current_track_idx], command_queue)
        if result == "next":
            current_track_idx += 1
        elif result == "prev":
            current_track_idx -= 1
        elif result is None:
            break  # 收到stop命令，终止播放
    
    print("播放结束！")

if __name__ == "__main__":
    main()

关键改动说明 #

• 线程安全队列：用queue.Queue实现控制线程和播放线程之间的命令传递，避免多线程共享变量的问题。
• 非阻塞命令获取：播放线程用get_nowait()尝试获取命令，队列空时直接跳过，不会被用户输入阻塞，能持续检查播放状态。
• 独立控制线程：控制线程持续运行监听用户输入，不会影响播放线程的状态检查，歌曲播放完就能自动触发切歌。
• 守护线程设置：控制线程设为守护线程，当主播放循环结束时，控制线程会自动退出，不用手动处理。

备注：内容来源于stack exchange，提问作者user29972411