class mhmclient:
tcp_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
tcp_socket.connect(('127.0.0.1', 8888))
def rece_msg(self):
print("接收:")
print(self.tcp_socket)
while True:
recv_msg = self.tcp_socket.recv(1024).decode("utf8")
print('接收到的信息为:%s' % recv_msg)
send_msg = "2222222222"
self.tcp_socket.send(send_msg.encode('utf-8'))
time.sleep(2)
def send_msg(self):
print("发送:")
print(self.tcp_socket)
while True:
send_msg = "1111111111"
self.tcp_socket.send(send_msg.encode('utf-8'))
time.sleep(2)
if __name__ == '__main__':
serv = mhmclient()
p1 = multiprocessing.Process(target=serv.send_msg(), args=())
p2 = multiprocessing.Process(target=serv.rece_msg(), args=())
p2.start()
p1.start()
1.两个进程没有一起执行,只看到了一个打印,线程是说有GIL,进程也破不了吗?
自定义的类里循环发送的方法,一开始用多线程,没成功,改成多进程了