Vertx 获取事件循环消息数
Vertx get event loop msg number
我正在尝试找到一种方法来获取我在事件循环中的当前消息数。
我想放置一些日志以了解消息是否正在排队。
我有这个迭代器,但我不认为它是因为 eventExecutor
Context context = vertx.getOrCreateContext();
ContextInternal contextInt = (ContextInternal) context;
EventLoop eventLoop = contextInt.nettyEventLoop();
此致。
如果将 .nettyEventLoop()
的结果转换为 NioEventLoop
,则可以调用 .pendingTasks
方法,该方法应提供有关事件循环中安排的任务数的信息。
NioEventLoop eventLoop = (NioEventLoop) ci.nettyEventLoop();
System.out.println(eventLoop.pendingTasks());
关于 NioEventLoop
实现的 JavaDoc:
https://netty.io/4.0/api/io/netty/channel/nio/NioEventLoop.html
我正在尝试找到一种方法来获取我在事件循环中的当前消息数。
我想放置一些日志以了解消息是否正在排队。
我有这个迭代器,但我不认为它是因为 eventExecutor
Context context = vertx.getOrCreateContext();
ContextInternal contextInt = (ContextInternal) context;
EventLoop eventLoop = contextInt.nettyEventLoop();
此致。
如果将 .nettyEventLoop()
的结果转换为 NioEventLoop
,则可以调用 .pendingTasks
方法,该方法应提供有关事件循环中安排的任务数的信息。
NioEventLoop eventLoop = (NioEventLoop) ci.nettyEventLoop();
System.out.println(eventLoop.pendingTasks());
关于 NioEventLoop
实现的 JavaDoc:
https://netty.io/4.0/api/io/netty/channel/nio/NioEventLoop.html