我目前正在使用以下代码来设置将在 Raspberry Pi 上运行的应用程序。将其设置为可以远程访问应用程序以进行输入和输出操作。在开始编写项目所需的代码之前,我试图了解这里发生了什么。
import socket
import threading
...
class chatServer(threading.Thread):
def __init__(self, (socket, address)):
threading.Thread.__init__(self)
self.socket = socket
self.address = address
def run(self):
lock.acquire()
clients.append(self)
lock.release()
print '%s:%s connected.' % self.address
while True:
data = self.socket.recv(1024)
if not data:
break
for c in clients:
c.socket.send(data)
self.socket.close()
print '%s:%s disconnected.' % self.address
lock.acquire()
clients.remove(self)
lock.release()
while True: # wait for socket to connect
# send socket to chatserver and start monitoring
chatServer( s.accept() ).start()
我不明白它是如何工作的。很明显,线程正在进行,一个以主线程结束的分支结束,等待与服务器建立任何新连接。新线程在 "def run(self): 函数中的 "while True:" 语句中循环。
但是为什么第二个线程挂在“while True:”循环中?“def run(self) 函数从未被调用过,为什么它会运行?
有只小跳蛙
相关分类