首页   注册   登录

fghjghf

V2EX 第 261862 号会员,加入于 2017-10-24 08:46:14 +08:00
今日活跃度排名 10022
fghjghf 最近回复了
不一样的方式?难道是免费送?
@taizhenhua1987 如果是菠菜有风险。这种不需要开发的,就需要你过包而已,现在菠菜很难上,换皮游戏的话,传奇上不了,国战和仙侠概率也比上一年低很多,今年苹果爸爸大整改,企业号从上一年的 4-5W 升到今年到 30-40W,因此很多人想上架,一来省钱二来大渠道有量。因为我公司就是做这种的,插边球生意,这类我都了解。凡事这种 iOS 外单,建议都不要接!!
都散了吧,肯定是那种菠菜,换皮游戏包上架过审。
2 天前
回复了 fghjghf 创建的主题 Python 急急急, Python 多进程,如何传递 epoll?
@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 传过去。
https://www.zhihu.com/question/66894127.
这算什么,建议大家有空多上逼乎。里面很多暴利点子的,月入保底 10 万。
不过可惜,最精彩的那几条被删了。不然真是刷三观。
你们聪明人都懂得
5 天前
回复了 fghjghf 创建的主题 Python 急急急, Python 多进程,如何传递 epoll?
@NoAnyLove 直接 callback 这个方法可行嘛,读写进程处理完就回调,让同一个进程去对 epoll 进程操作
5 天前
回复了 fghjghf 创建的主题 Python 急急急, Python 多进程,如何传递 epoll?
@NoAnyLove 这个我试过,是同一个内存地址。然后你再试一试,用你传过去的 epoll. modify.发现并不管用。
其实我只是想做个:半同步半异步服务器。gil 锁所以用进程。主进程负责循环监听 socket,遇到可读可写,就放入进程池执行读写逻辑,非堵塞执行,遇到 eagain,需要 epoll.modify(out)然后结束。那么主进程也能检测到 fd 状态。如此循环...请问这个逻辑到底那里错了,或者需要怎么做,能大致点一下嘛
5 天前
回复了 WPMonkey 创建的主题 奇思妙想 说一下你的创业 idea
不忽悠你。区块链,智能合约,搞个菠菜游戏,棋牌类。你就收房费。搞一千几百个用户就行,熟人推广。用免签支付。每个一天十块几块的肯定有。一个月收入 10 万保底。去吧骚年。别的就别想太多了,根本切不进去,不是没资金,就是技术水平不足以支撑这个理念或产品
关于   ·   FAQ   ·   API   ·   我们的愿景   ·   广告投放   ·   感谢   ·   实用小工具   ·   3206 人在线   最高记录 5043   ·  
创意工作者们的社区
World is powered by solitude
VERSION: 3.9.8.3 · 8ms · UTC 10:36 · PVG 18:36 · LAX 03:36 · JFK 06:36
♥ Do have faith in what you're doing.
沪ICP备16043287号-1