Verticles - 异步Verticle启动和停止

优质
小牛编辑
127浏览
2023-12-01

实现异步启动

下面是一个示例:

  1. public class MyVerticle extends AbstractVerticle {
  2. public void start(Future<Void> startFuture) {
  3. // Now deploy some other verticle:
  4. vertx.deployVerticle("com.foo.OtherVerticle", res -> {
  5. if (res.succeeded()) {
  6. startFuture.complete();
  7. } else {
  8. startFuture.fail();
  9. }
  10. });
  11. }
  12. }

同样地,也是 stop 方法也是异步。如果你想要做一些verticle的清理工作,这需要一些时间,则如此使用。

  1. public class MyVerticle extends AbstractVerticle {
  2. public void start() {
  3. // Do something
  4. }
  5. public void stop(Future<Void> stopFuture) {
  6. obj.doSomethingThatTakesTime(res -> {
  7. if (res.succeeded()) {
  8. stopFuture.complete();
  9. } else {
  10. stopFuture.fail();
  11. }
  12. });
  13. }
  14. }

信息: 你不需要在启动一个verticle后手动取消部署子 verticles,在verticle的 stop 方法。当父verticle’s取消部署时,Vert.x 将自动取消部署任何子 verticles。