Netty之EventLoop

2023-04-04 54

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

简介： EventLoop本质是一个单线程执行器（同时维护了一个Selector），里面有run方法处理channel上源源不断的io事件。

1、什么是EventLoop

EventLoop本质是一个单线程执行器（同时维护了一个Selector），里面有run方法处理channel上源源不断的io事件。

2、什么是EventLoopGroup

EventLoopGroup是一组EventLoop，Channel一般会调用EventLoopgroup的register方法来绑定其中一个EventLoop，后续这个Channel上的io事件都由此EventLoop来处理（保证io事件处理时的线程安全）。

NioEventLoopGroupeventExecutors=newNioEventLoopGroup();

NioEventLoopGroup默认线程数为当前CPU核心数*2；如果有传参则以传参为准。

NioEventLoopGroup支持IO事件，普通任务事件，定时任务事件。

示例：

packagenetty.c2;
importio.netty.channel.nio.NioEventLoopGroup;
importjavafx.scene.layout.GridPane;
importjava.util.concurrent.TimeUnit;
publicclassTestEventLoop {
publicstaticvoidmain(String[] args) {
NioEventLoopGroupeventExecutors=newNioEventLoopGroup(2);
System.out.println(eventExecutors.next());
System.out.println(eventExecutors.next());
System.out.println(eventExecutors.next());
System.out.println(eventExecutors.next());
// 执行普通任务//        eventExecutors.next().submit(() -> {//            try {//                System.out.println("thread");//                Thread.sleep(1000);//            } catch (InterruptedException e) {//                e.printStackTrace();//            }//        });//        System.out.println("main");// 执行定时任务eventExecutors.next().scheduleAtFixedRate(() -> {
try {
System.out.println("thread");
Thread.sleep(1000);
            } catch (InterruptedExceptione) {
e.printStackTrace();
            }
        }, 0, 1, TimeUnit.SECONDS);
    }
}