3

我在 python 中的选择有问题，我有一段代码允许客户端从服务器接收数据并通过在标准输入上读取并在服务器套接字上写入来发送它：

readfds = [s, sys.stdin]
writefds = [s, sys.stdout]
my_level = get_my_level(s)
is_co = True
cmd = ""
while (is_co):
    read, write, exception = select.select(readfds, writefds, [], 1)
    if (not (read or write or exception)):
        print "Timeout"
    else:
        for sock in read:
            if (sock == s):
                cmd = readline(s)
                print cmd
            elif (sock == sys.stdin):
                cmd = sys.stdin.readline()
                s.sendall(cmd)
     if (cmd == "mort"):
        is_co = False

我认为这是因为选择是非阻塞的，但是当我让它阻塞时，它是同一回事。您能解释一下我的代码中的 wath 错误吗？

谢谢

4

2 回答 2

5

大概你总是可以写信，sys.stdout所以select.select应该立即返回，让你知道你可以写一些东西。该代码然后处理可读列表，然后重新进入循环。但是没有任何改变，sys.stdout所以它仍然是可写的。

这将在一个紧密的循环中执行并烧毁 CPU。

于 2013-07-02T17:21:27.123 回答
0

我遇到了类似的问题，所以我不断地轮询套接字（在我的例子中是 UDP）并使用 sleep() 超时。在这段代码中，CPU 使用率从 100% 变为大约 4%

sUDP = socket.socket(socket.AF_INET, socket.SOCK_DGRAM, socket.IPPROTO_UDP)
sUDP.bind((host, portIn))
sUDP.setblocking(0)
sUDP.settimeout(0.5)

while True:
    try:
        data, addr = sUDP.recvfrom(4096)
        ... #some data processing code here
    except:
        time.sleep(0.02)
于 2015-11-16T21:21:26.970 回答