dubbo的线程
2022-03-15 19:04:35 2 举报
dubbo的线程同步异步
作者其他创作
大纲/内容
数据类型
客户端
将结果包装成Response对象通过channel发送给消费端
线程
accept
请求
workGroup (iothreads个线程)
响应
write/read
执行同步服务
connected/received
CompletionStage.whenComplete()
channel.writeAndFlush(message)
DefaultFuture.doReceive(response)给消费端设置结果或异常并完成
执行异步服务
threadpool (threads个线程)
异步触发
同步执行服务将结果封装为（CompletionStage）
异步执行服务，预先返回（CompetionStage）
bossGroup
直接触发
将当前的channel，事件类型，接收到的数据封装成channelEventRunnable提交给threadpool的线程异步进行处理，随后io线程继续处理其他io事件
send(response.false)
AllChannelHandler
ChannelEventRunnable
0 条评论
回复 删除
下一页
