大佬们速来，python多进程如何传递epoll?

1. 
   

复制代码

1. process_num = 2*cpu_count()
   
2.         # 设置进程池、消息队列
   
3.         po = Pool(process_num)
   
4.         q = Manager().Queue() #ipc方法1
   
5.         m=Manager()  # ipc方法2
   
6. 
   
7.         # 初始化并监听epoll
   
8.         epoll_fd = select.epoll()
   
9.         epoll_fd.register(serverSocket.fileno(), select.EPOLLIN)
   
10. 
    
11.         connections = {}
    
12.         addresses = {}
    
13.        
    
14. 
    
15.         # 循环接收请求
    
16.         while True:
    
17.                 # epoll 进行 fd 扫描的地方 -- 未指定超时时间则为阻塞等待
    
18.                 epoll_list = epoll_fd.poll()
    
19.                 for fd, events in epoll_list:
    
20.                         print("fd is:%s events is%s"%(fd,events))
    
21.                         if fd == serverSocket.fileno():
    
22. 
    
23.                                 conn, addr = serverSocket.accept()
    
24.                                 conn.setblocking(False)
    
25.                                 epoll_fd.register(conn.fileno(), select.EPOLLIN  | select.EPOLLET )
    
26. 
    
27.                                 connections[conn.fileno()] = conn
    
28.                                 addresses[conn.fileno()] = addr
    
29. 
    
30. 
    
31.                         elif events & select.EPOLLIN:
    
32.                                
    
33.                                
    
34.                                
    
35.                                 q.put(connections[fd])
    
36.                                 po.apply_async(workProcess4In,(q,epoll_fd)) # 非阻塞-进程池
    
37. 
    
38.                         elif events & select.EPOLLOUT:
    
39.                                 q.put(fd)
    
40.                                 # d=m.dict({"epollfd":epoll_fd,"fd":fd})
    
41.                                 po.apply_async(workProcess4Out,(fd,epoll_fd))
    
42.         po.close()
    
43.         po.join()
    
44. <div class="blockcode"><blockquote>def workProcess4In(q):
    
45.         # print("消息队列有：%s"%q.qsize())
    
46.         print("共享内存 is:%s"%q)
    
47.         # d["epollfd"].modify(d["fd"],select.EPOLLET | select.EPOLLOUT)
    
48.         # a = q.get()
    
49.         # 实验性，不行就放共享内存
    
50.         # epoll_fd = select.epoll()
    
51.         # epoll_list1 = epoll_fd.poll()
    
52.         print(epoll_list)
    
53.         # print("epoll2 is:%s"%epoll_fd)
    
54.         # print("a的文件描述符是%s"%a[1])
    
55.         epoll_fd.modify(a, select.EPOLLET | select.EPOLLOUT)

复制代码

半同步半异步。主进程负责接收请求，收到请求后，分发给其他进程处理。现在都问题是：epoll_fd传不过去其他进程。无论是用代码里面都q，还是m。2个IPC方法都不行。或者直接在apply_async的参数传。都无法传过去。困扰很久，请大佬们帮帮忙

最后有没有解啊，多进程间的pipe也不行吗？

epoll事件机制在内核层有个惊群效应，epoll事件的到来会唤醒监听在这个端口上的所有进程，这些进程在执行accept操作的时候内核只会唤醒一个进程，这个client的fd就会只存在在一个进程里，epoll事件会唤醒所有的进程，但event只在一个client的fd上。建议看看epoll惊群现象的描述，nginx为了减缓这种惊群现象使用了锁机制。