Python代码，我应该线程吗？该怎么办？

Question

我有这段代码，它通过套接字侦听命令“更新的播放列表”。 当它得到这个命令时，它知道数据库中的播放列表已经更新，它连接到数据库并下载新的播放列表，然后开始播放这些文件。 我正在尝试找到解决此问题的最佳方法，因为当它获取命令，然后调用 Media_Player 函数时，它将播放播放列表中的所有视频，然后返回侦听套接字。

与此同时，如果已发送另一个“更新播放列表”命令，则此命令的发送者会收到错误消息，因为此代码不会监听。我希望媒体播放器不间断地播放，但它也必须不断收听，以防被告知已添加新的播放列表。

然后，如果添加了新的播放列表，它就会知道，当播放列表中的一个文件播放完毕时，它可以切换到新的播放列表并继续播放。

我不知道该怎么做，我以为我可以在一个进程中完成所有操作，然后为播放列表中的每个文件生成一个新线程，这样它就可以直接回到收听状态，但是那我怎么知道线程何时结束，因为播放列表中的每个文件的长度都不同。

还在函数listen_serv()中看到'return data'这一行，这是否意味着它不会因为返回而关闭连接？

# Echo server program
import socket
import time
import Database as DB

def listen_serv():
    HOST = ''                 # Symbolic name meaning all available interfaces
    PORT = 50007              # Arbitrary non-privileged port
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))
    s.listen(1)
    conn, addr = s.accept()
    print 'Connected by', addr
    while 1:
        data = conn.recv(1024)
        if not data: break
        conn.sendall('OK')
        return data

    conn.close()


while 1:
    val= listen_serv()
    if val=='Updated Playlist':
        PlayList = DB.get_play_list()
        Media_Player(PlayList)#This isnt implemented yet

Answer 1

您可以运行两个进程，一个是服务器，另一个是 MediaPlayer，中间有一个队列。

服务器将命令推送到 MediaPlayer 弹出它们的队列，播放每个视频后只需检查队列中是否有任何内容，如果有弹出并播放新的播放列表。

import socket
import time
import Database as DB
from multiprocessing import Process, Queue

def listen_serv(queue):
    HOST = ''                 # Symbolic name meaning all available interfaces
    PORT = 50007              # Arbitrary non-privileged port
    s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
    s.bind((HOST, PORT))
    s.listen(1)
    conn, addr = s.accept()
    print 'Connected by', addr
    while 1:
        data = conn.recv(1024)
        if not data:
            break
        conn.sendall('OK')
        queue.put(data)
    conn.close()

def media_player(queue):
    while 1:
        val = queue.get() # This will block until theres something on the queue.
        if val == 'Updated Playlist':
            PlayList = DB.get_play_list()
            Media_Player(PlayList, queue) # Media_Player needs to check the queue and update when appropriate.


if __name__ == '__main__':
    q = Queue()
    server = Process(target = listen_serv, args = (q,))
    media_player = Process(target = media_player, args = (q,))
    server.start()
    media_player.start()
    server.join()
    media_player.join()

你可以通过queue.empty()检查队列是否为空 我确信那里有更好的实现，如果有错误/问题我深表歉意。

祝你好运。