netty的启动过程是咋样的,就是那里启动了socket监听,咋处理请求的( 六 )
终于,我们在RegisterTask类中run方法里面看到了我们想要的信息,channel.socket.register(selector, SelectionKey.OP_ACCEPT, channel); protected final void registerTask(Runnable task) { taskQueue.add(task); Selector selector = this.selector; if (selector != null) { if (wakenUp.compareAndSet(false, true)) { selector.wakeup(); } } else { if (taskQueue.remove(task)) { // the selector was null this means the Worker has already been shutdown. throw new RejectedExecutionException("Worker has already been shutdown"); } } }然后这个RegisterTask怎么执行的呢,我们看registerTask方法发现,这个registerTask被放进一个taskQueue里面了
推荐阅读
- 强寒潮来袭浙江启动低温雨雪冰冻灾害Ⅳ级应急响应
- 西藏航空一机长执飞过程中身体不适降落后送医去世
- 江苏省13市启动重污染天气黄色预警
- 兰州启动进口冷链食品监管总仓“出仓”须查验证明
- 朋友圈直播酒驾全过程?警方:当事人涉嫌酒驾接受调查
- “艺术无障碍平台”正式启动
- |共促和谐劳动关系 工会法律和集体协商技能竞赛启动
- 正点财经|
- |苏州·中国声学创新谷在常熟启动
- 大三学生准备日本留学过程中要不要准备考研
