我最近拿起了python,我正在尝试学习更多关于网络的知识。我遇到了一个问题,我试图使用多线程同时侦听和发送数据。这是代码:
import socket
from threading import Thread
name = ""
s = socket.socket()
def Main():
print("What is your name?")
name = input("Name: ")
Connect()
def Connect():
host = '127.0.0.1'
port = 5000
s.connect((host, port))
Thread(target=Send()).start()
print("oh")
Listen()
def Listen():
while True:
data, addr = s.recvfrom(1024)
data = data.decode('utf-8')
if not data:
break
print(data)
def Send():
message = input(name + ": ")
while message != 'q':
s.send(message.encode("utf-8"))
message = input(name + ": ")
s.close()
Main()
问题是,当创建Thread
时,程序卡在Send()
函数的while循环中,并且它永远不会调用Listen()
函数。我添加了一个print()
函数来调试创建线程后是否发生任何事情。
这是我得到的输出:
你叫什么名字?
名称: 流R
:测试
:
您正在调用 Send()
函数而不是将其作为参数传递,这就是它阻塞的原因。
target=Send()
后删除()
:
Thread(target=Send).start()