我是 Vert.x 的新手。
例如,JDBCClient
有非阻塞方法
JDBCClient.getConnection(Handler<AsyncResult<SQLConnection>> handler)
当我调用它时,它真的是异步的。
jdbcClient.getConnection(result -> { /* this code will execute asynchonous */})
但是如何使用非阻塞方法实现我自己的组件呢?
当我写这个例子时,它看起来并不异步。它只会执行方法体,然后调用传递的 lambda。
class MyComponent {
public void getSomething(Handler<AsyncResult<String>> handler) {
String result = someHeavyMethodInThisThread();
handler.handle(Future.succeededFuture(result));
}
}
/* later */
/* this code will be blocking, right? */
myComponent.getSomething(res -> { /* ... */ })
也许有办法告诉 Vert.x 我的方法应该是异步的?一些注释或其他什么?
最佳答案
你的代码没有问题,你的代码风格通常是异步的,因为当你执行 IO 操作或调用 vert.x API 时,异步操作将使你脱离当前线程(事件循环)。
在您的情况下,您正在执行 CPU 绑定(bind)代码,因此它不会表现得像异步一样,正如您所说,只会调用 lambda。如果你仍然想让它异步,你总是可以用 runOnContext
包装你的代码,这将使它排队在事件循环的下一次迭代中运行,例如:
class MyComponent {
public void getSomething(Handler<AsyncResult<String>> handler) {
vertx.runOnContext(v -> {
String result = someHeavyMethodInThisThread();
handler.handle(Future.succeededFuture(result));
});
}
}
关于java - 如何在 Vert.x 中实现自定义异步操作?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47460419/