如何使用线程在 Python Twisted 服务器中同时运行多个连续任务？

Question

假设您有 1000 个客户端连接到一个扭曲的服务器。这些客户端不断地轮询更新（或者只是通过WebSocket 之类的东西持续连接）。服务器的工作是遍历所有 1000 个，检查其中哪些有更新，然后在更新时将其发送出去。

有没有办法做到，在 Twisted 中，我可以在 4 个线程中运行 250 个（或者进一步划分它）？ Twisted 如何决定一次运行多少个任务？我可以连续检查250，甚至不时更改分布吗？

这是我想象的一个非常简单的版本，虽然我不知道它在 Twisted 中的样子：

class Server:

    queues = [["250 clients"], ["250 clients"], ["250 clients"], ["250 clients"]]

    @classmethod
    def run_server(cls):
        for i in xrange(len(cls.queues)):
            # this would run in its own thread
            cls.continuously_check_for_updates(cls.queues[i])

        # server mainloop
        while True:
            if get_client_connection():
                store_client_in_queue()
                distribute_client_queues()

    @classmethod
    def continuously_check_for_updates(cls, queue):
        i = 0
        while True:
            if i >= len(queue):
                i = 0

            client = queue[i]
            if check_for_updates(client):
                report_update(client)

            i += 1
    

感谢您的洞察力和建议。谢谢。

Answer 1

没有。 Python 一次只会执行一个线程（忽略一些不相关的细节）。没有理由使用线程来解决这个问题。

相反，您应该使用一种您没有的事件驱动方法来不断检查一千种不同的数据结构。而是在发生相关变化时采取行动。

例如，不要写这样的程序：

def addSomeData(data):
    someList.append(data)

def checkForData():
    if someList:
        return someList.pop(0)
    return None

while True:
    data = checkForData()
    if data is not None:
        processData(data)

改为编写这样的程序：

def addSomeData(data):
    processData(data)

它更简单、更高效。