rpc服务器【多线程同步】模型

1
多线程处理 需要开启一个新的线程去处理RPC的通信,接着上 单线程同步 的代码

rpc【单线程同步】模型

1
_thread.start_new_thread(fun,(params...))
1
2
3
4
5
6

import _thread
def loop(s, handlers):
while True:
conn, addr = s.accept()
_thread.start_new_thread(handle_conn, (conn, addr, handlers)) # 处理连接)