本文目录
- inEventLoop()方法有什么
- eventloopgroup 在哪个jar
- anylogic弹出eventloop
- 动态心电图检测仪上loop和event啥意思
- netty极简教程（七）：Netty中的Selector是如何配合NioEventLoop工作的
- 如何处理Unhandled event loop exception的异常
inEventLoop()方法有什么
线程模型啊NioEventLoop相对NioEventLoopGroup来说就复杂很多了，需要一定的耐心来看这篇文章。首先从NioEventLoop的启动讲起，对于线程池来说，启动一般都是从第一个任务的添加开始的。经过跟踪，找到execute()方法在SingleThreadEventExecutor类中： view plain copypublic void execute(Runnable task) { if (task == null) { throw new NullPointerException("task"); } // inEventLoop表示启动线程与当前线程相同，相同表示已经启动，不同则有两种可能：未启动或者线程不同 boolean inEventLoop = inEventLoop(); if (inEventLoop) { // 运行中则直接添加任务到队列中 addTask(task); } else { // 尝试启动任务 startExecution(); // 将任务加到任务队列taskQueue中 addTask(task); // 发现已经关闭则移除任务并拒绝 if (isShutdown() && removeTask(task)) { reject(); } } if (!addTaskWakesUp && wakesUpForTask(task)) { // 唤醒执行线程 wakeup(inEventLoop); } } private void startExecution() { // 未启动的状态下才进行启动 if (STATE_UPDATER.get(this) == ST_NOT_STARTED) { if (STATE_UPDATER.compareAndSet(this, ST_NOT_STARTED, ST_STARTED)) { // 增加一个定时任务，该任务将定时任务队列中的已取消任务从队列中移除，该任务每间隔1秒执行1次 schedule(new ScheduledFutureTask《Void》( this, Executors.《Void》callable(new PurgeTask(), null), ScheduledFutureTask.deadlineNanos(SCHEDULE_PURGE_INTERVAL), -SCHEDULE_PURGE_INTERVAL)); // 开始执行 scheduleExecution(); } } } // 如果已经关闭了，则不能再加任务，否则加入到任务队列中 protected void addTask(Runnable task) { if (task == null) { throw new NullPointerException("task"); } if (isShutdown()) { reject(); } taskQueue.add(task); }
eventloopgroup 在哪个jar
在Netty框架初探中，当我们启动客户端或者服务端时，都要声明一个Group对象 view plain copyEventLoopGroup group = new NioEventLoopGroup(); 这里我们就以NioEventLoopGroup来说明。先看一下它的继承关系 view plain copyNioEventLoopGroup extends MultithreadEventLoopGroup extends MultithreadEventExecutorGroup 看看NioEventLoopGroup的构造函数 view plain copypublic NioEventLoopGroup() { this(0); } //他会连续调用内部的构造函数，直到用下面的构造去执行父类的构造 //nThreads此时为0，马上就会提到这个参数的用处 public NioEventLoopGroup( int nThreads, Executor executor, final SelectorProvider selectorProvider) { super(nThreads, executor, selectorProvider); } 基类MultithreadEventLoopGroup的构造 view plain copyprotected MultithreadEventLoopGroup(int nThreads, ThreadFactory threadFactory, Object... args) { super(nThreads == 0 ? DEFAULT_EVENT_LOOP_THREADS : nThreads, threadFactory, args); } //nThreads：内部线程数，如果为0，就取默认值，通常我们会设置为处理器个数*2 DEFAULT_EVENT_LOOP_THREADS = Math.max(1, SystemPropertyUtil.getInt( "io.netty.eventLoopThreads", Runtime.getRuntime().availableProcessors() * 2)); 继续调用再上一级的MultithreadEventExecutorGroup的构造 view plain copy//这里会根据nThreads创建执行者数组 private final EventExecutor children; protected MultithreadEventExecutorGroup(int nThreads, Executor executor, Object... args) { if (nThreads 《= 0) { throw new IllegalArgumentException(String.format("nThreads: %d (expected: 》 0)", nThreads)); } if (executor == null) { executor = new ThreadPerTaskExecutor(newDefaultThreadFactory()); } //这里创建EventExecutor数组对象 children = new EventExecutor; if (isPowerOfTwo(children.length)) { chooser = new PowerOfTwoEventExecutorChooser(); } else { chooser = new GenericEventExecutorChooser(); } //此处循环children数组，来创建内部的NioEventLoop对象 for (int i = 0; i 《 nThreads; i ++) { boolean success = false; try { //newChild是abstract方法，运行期会执行具体的实例对象的重载 children = newChild(executor, args); success = true; } catch (Exception e) { // TODO: Think about if this is a good exception type throw new IllegalStateException("failed to create a child event loop", e); } finally { //如果没有成功，做关闭处理 if (!success) { for (int j = 0; j 《 i; j ++) { children.shutdownGracefully(); } for (int j = 0; j 《 i; j ++) { EventExecutor e = children; try { while (!e.isTerminated()) { e.awaitTermination(Integer.MAX_VALUE, TimeUnit.SECONDS); } } catch (InterruptedException interrupted) { // Let the caller handle the interruption. Thread.currentThread().interrupt(); break; } } } } } ...... } 因为我们最初创建的是NioEventLoopGroup对象，所以newChild会执行NioEventLoopGroup的newChild方法，创建NioEventLoop对象。 view plain copy@Override protected EventLoop newChild(Executor executor, Object... args) throws Exception { return new NioEventLoop(this, executor, (SelectorProvider) args); } 看看NioEventLoop的继承关系 view plain copyNioEventLoop extends SingleThreadEventLoop extends SingleThreadEventExecutor NioEventLoop通过自己的构造行数，一直调用到SingleThreadEventExecutor的构造 view plain copyprotected SingleThreadEventExecutor(EventExecutorGroup parent, Executor executor, boolean addTaskWakesUp) { super(parent); if (executor == null) { throw new NullPointerException("executor"); } this.addTaskWakesUp = addTaskWakesUp; this.executor = executor; taskQueue = newTaskQueue(); } 至此，Group和内部的Loop对象以及Executor就创建完毕，那么他们是什么时候被调用的呢？就是在服务端bind和客户端connect时。服务端的bind方法执行的是AbstractBootstrap的bind方法，bind方法中先会调用validate()方法检查是否有group view plain copy@SuppressWarnings("unchecked") public B validate() { if (group == null) { throw new IllegalStateException("group not set"); } if (channelFactory == null) { throw new IllegalStateException("channel or channelFactory not set"); } return (B) this; } 所以，假如初始时，没有设置Bootstrap的group的话，就会报错。最终bind调用doBind，然后调用doBind0，启动一个Runnable线程 view plain copyprivate static void doBind0( final ChannelFuture regFuture, final Channel channel, final SocketAddress localAddress, final ChannelPromise promise) { // This method is invoked before channelRegistered() is triggered. Give user handlers a chance to set up // the pipeline in its channelRegistered() implementation. channel.eventLoop().execute(new Runnable() { @Override public void run() { if (regFuture.isSuccess()) { channel.bind(localAddress, promise).addListener(ChannelFutureListener.CLOSE_ON_FAILURE); } else { promise.setFailure(regFuture.cause()); } } }); } 我们这里，channel.eventLoop()得到的是NioEventLoop对象，所以执行NioEventLoop的run方法，开始线程运行。我们在创建Bootstrap初期，会调用它的group方法，绑定一个group，这样，一个循环就开始运行了。
anylogic弹出eventloop
t单线程运行时不会阻塞。EventLoop即事件循环，是指浏览器或Node的一种解决javaScript单线程运行时不会阻塞的一种机制，也就是经常使用异步的原理。
动态心电图检测仪上loop和event啥意思
event是用来记录发生事件的，用来查询动态心电图在某一个时间发生的某些事件，这种情况问题不大。可以放心。动态心电图多可用来监测心律失常，可根据结果来调整用药。
netty极简教程（七）：Netty中的Selector是如何配合NioEventLoop工作的
上一节我们找到了ServerSocketChannel的生成，注册Selector，绑定端口启动等等： netty极简教程（六）：Netty是如何屏蔽ServerSocketChannel启动的 ， 接下来接续验证在Netty中Selector的生成使用以及我们jdk 原生工作线程再netty中是怎么启动工作的: NioEventLoopGroup ***隐藏网址***接着继续往下面走，它将children全部实例化并且该children是一个NioEventLoop实例数组（将上面的executor丢了进去）； 所以现在关键地方在于，这个NioEventLoop是什么时候往ThreadPerTaskExecutor丢了一个任务，我们继续追踪它NioEventLoop我们回到上一节解析的 registerAndInit() 方法即先走下面的 最终使用executor提交开启了一个新线程（忘记的回忆一下ThreadPerTaskExecutor)：最后会触发SererSocketChannel中pipeline中的read方法，此时我们在上一节已经埋好伏笔，就是 ServerBootstrapAcceptor 的read会触发，从而将新接受的连接SocketChannel再次注册到selector，并且work子线程也会开始无限循环并进行上面的操作：
如何处理Unhandled event loop exception的异常
这个是因为软件影响，你看下是哪个软件 查找是受哪个程序影响的办法：打开任务管理器，逐个kill你不知道的用户进程，每杀一个，就重启eclipse看是否解决了。 在系统启动时，想要不再加载这两个进程，可以通过msconfig命令在启动项里取消了AMD HydraVision Desktop Manager和Catalyst Control Center。
