10

2019-06-16 15:39:41 +08:00

@NoAnyLove 好的好的，我查了下，說 IPC 或向 worker 參數傳遞的東西必須要能 pickle，不然就報錯，那就是 select.epoll 是不支持的。error：TypeError: can't pickle select.epoll objects。

代碼大致如下：

def listenProcess(serverSocket):

process_num = 2*cpu_count()

# 設置進程池、消息隊列

po = Pool(process_num)

q = Manager().Queue() #ipc 方法 1

m=Manager() # ipc 方法 2

epoll_fd = select.epoll()

epoll_fd.register(serverSocket.fileno(), select.EPOLLIN)

# 保存中間數據

connections = {}

addresses = {}

while True:

epoll_list = epoll_fd.poll()

for fd, events in epoll_list:

print("fd is:%s events is%s"%(fd,events))

if fd == serverSocket.fileno():

conn, addr = serverSocket.accept()

conn.setblocking(False)

epoll_fd.register(conn.fileno(), select.EPOLLIN | select.EPOLLET )

connections[conn.fileno()] = conn

addresses[conn.fileno()] = addr

elif events & select.EPOLLIN:

# q.put(connections[fd])

po.apply_async(workProcess4In,args=(connections[fd],epoll_fd,))

elif events & select.EPOLLOUT:

# q.put(fd)

# d=m.dict({"epollfd":epoll_fd,"fd":fd})

po.apply_async(workProcess4Out,(connections[fd,epoll_fd],))

po.close()

po.join()

def workProcess4In(conn,epollfd):

#print("epoll is:%s"%epollfd)

#執行讀操作，遇到 eagain 就 modify 狀態 out

epollfd.modify(conn.fileno(), select.EPOLLET | select.EPOLLOUT)

執行結果：不執行 workProcess4In，如果把 epoll_fd 換成其他，則沒問題

請教 dalao，主進程需要如何才能把 epoll_fd 傳過去。