/**
* @author ycw
* @version v1.0
* @date 2022/3/28 14:23
* @description
*/
@Slf4j
public class TestEventLoop {
public static void main(String[] args) {
EventLoopGroup group = new NioEventLoopGroup(2); //io事件 普通任务 定时任务
//System.out.println(NettyRuntime.availableProcessors());获取CPU核心数
group.next();//获取下一个循环对象
group.next().submit(()->{
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
log.debug("=========ok");
});//普通任务
group.next().scheduleAtFixedRate(()->{
log.debug("=======Hello");
},0,2, TimeUnit.SECONDS);
log.debug("main");
}
}
EventLoopGroup是一个事件循环组,EventLoop是事件循环对象实现了定时线程池的接口以及netty本身的接口OrderedEventExecutor,里面的线程数默认是CPU核心线程数的两倍。你也可以指定其初始化线程数。EventLoop可以实现异步和定时处理任务的需求。
版权声明:本文为qq_33965490原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。