io.vertx.core.Context.isOnVertxThread()方法的使用及代码示例

x33g5p2x  于2022-01-18 转载在 其他  
字(9.8k)|赞(0)|评价(0)|浏览(178)

本文整理了Java中io.vertx.core.Context.isOnVertxThread()方法的一些代码示例，展示了Context.isOnVertxThread()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Context.isOnVertxThread()方法的具体详情如下：
包路径：io.vertx.core.Context
类名称：Context
方法名：isOnVertxThread

Context.isOnVertxThread介绍

[英]Is the current thread a Vert.x thread? That's either a worker thread or an event loop thread
[中]当前线程是否为顶点。x线？这是工作线程或事件循环线程

代码示例

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 public void stop() throws Exception {
  assertTrue(Context.isOnVertxThread());
  assertFalse(Context.isOnWorkerThread());
  assertTrue(Context.isOnEventLoopThread());
 }
};

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public void start() throws Exception {
 assertTrue(Context.isOnVertxThread());
 assertFalse(Context.isOnWorkerThread());
 assertTrue(Context.isOnEventLoopThread());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
public void start() throws Exception {
 assertTrue(Context.isOnVertxThread());
 assertTrue(Context.isOnWorkerThread());
 assertFalse(Context.isOnEventLoopThread());
}

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 public void stop() throws Exception {
  assertTrue(Context.isOnVertxThread());
  assertTrue(Context.isOnWorkerThread());
  assertFalse(Context.isOnEventLoopThread());
 }
};

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 public void start() throws Exception {
  vertx.executeBlocking(fut -> {
   thread.set(Thread.currentThread());
   assertTrue(Context.isOnVertxThread());
   assertTrue(Context.isOnWorkerThread());
   assertFalse(Context.isOnEventLoopThread());
   assertTrue(Thread.currentThread().getName().startsWith(poolName + "-"));
   fut.complete();
  }, onSuccess(v -> {
   vertx.undeploy(context.deploymentID());
  }));
 }
}, new DeploymentOptions().setWorkerPoolName(poolName), onSuccess(v -> {}));

代码示例来源：origin: eclipse-vertx/vert.x

@Override
 public void start() throws Exception {
  thread.set(Thread.currentThread());
  assertTrue(Context.isOnVertxThread());
  assertTrue(Context.isOnWorkerThread());
  assertFalse(Context.isOnEventLoopThread());
  assertTrue(Thread.currentThread().getName().startsWith(poolName + "-"));
  context.runOnContext(v -> {
   vertx.undeploy(context.deploymentID());
  });
 }
}, new DeploymentOptions().setWorker(true).setWorkerPoolName(poolName), onSuccess(deployment::set));

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testThread() {
 String poolName = TestUtils.randomAlphaString(10);
 WorkerExecutor worker = vertx.createSharedWorkerExecutor(poolName);
 AtomicBoolean onVertxThread = new AtomicBoolean();
 AtomicBoolean onWorkerThread = new AtomicBoolean();
 AtomicBoolean onEventLoopThread = new AtomicBoolean();
 AtomicReference<String> threadName = new AtomicReference<>();
 worker.executeBlocking(fut -> {
  onVertxThread.set(Context.isOnVertxThread());
  onWorkerThread.set(Context.isOnWorkerThread());
  onEventLoopThread.set(Context.isOnEventLoopThread());
  threadName.set(Thread.currentThread().getName());
  fut.complete(null);
 }, ar -> {
  testComplete();
 });
 // Use regular assertions because the thread name does not start with "vert.x-"
 // and it confuses the VertxTestBase asserts
 assertWaitUntil(() -> threadName.get() != null);
 assertTrue(onVertxThread.get());
 assertTrue(onWorkerThread.get());
 assertFalse(onEventLoopThread.get());
 assertTrue(threadName.get().startsWith(poolName + "-"));
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testStandardRightThread() throws Exception {
 assertFalse(Context.isOnVertxThread());
 Verticle verticle = new AbstractVerticle() {
  @Override
  public void start() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
  }
  @Override
  public void stop() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
  }
 };
 vertx.deployVerticle(verticle, onSuccess(res -> {
  assertTrue(Context.isOnVertxThread());
  assertFalse(Context.isOnWorkerThread());
  assertTrue(Context.isOnEventLoopThread());
  vertx.undeploy(res, onSuccess(res2 -> {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
   testComplete();
  }));
 }));
 await();
}

代码示例来源：origin: eclipse-vertx/vert.x

@Test
public void testWorkerRightThread() throws Exception {
 assertFalse(Context.isOnVertxThread());
 Verticle verticle = new AbstractVerticle() {
  @Override
  public void start() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertTrue(Context.isOnWorkerThread());
   assertFalse(Context.isOnEventLoopThread());
  }
  @Override
  public void stop() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertTrue(Context.isOnWorkerThread());
   assertFalse(Context.isOnEventLoopThread());
  }
 };
 vertx.deployVerticle(verticle, new DeploymentOptions().setWorker(true), onSuccess(res -> {
  assertTrue(Context.isOnVertxThread());
  assertFalse(Context.isOnWorkerThread());
  assertTrue(Context.isOnEventLoopThread());
  vertx.undeploy(res, onSuccess(res2 -> {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
   testComplete();
  }));
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public void start() throws Exception {
 assertTrue(Context.isOnVertxThread());
 assertFalse(Context.isOnWorkerThread());
 assertTrue(Context.isOnEventLoopThread());
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public void start() throws Exception {
 assertTrue(Context.isOnVertxThread());
 assertTrue(Context.isOnWorkerThread());
 assertFalse(Context.isOnEventLoopThread());
}

代码示例来源：origin: io.vertx/vertx-core

@Override
public void start() throws Exception {
 assertTrue(Context.isOnVertxThread());
 assertTrue(Context.isOnWorkerThread());
 assertFalse(Context.isOnEventLoopThread());
}

代码示例来源：origin: io.vertx/vertx-core

@Override
 public void stop() throws Exception {
  assertTrue(Context.isOnVertxThread());
  assertTrue(Context.isOnWorkerThread());
  assertFalse(Context.isOnEventLoopThread());
 }
};

代码示例来源：origin: io.vertx/vertx-core

@Override
 public void start() throws Exception {
  vertx.executeBlocking(fut -> {
   thread.set(Thread.currentThread());
   assertTrue(Context.isOnVertxThread());
   assertTrue(Context.isOnWorkerThread());
   assertFalse(Context.isOnEventLoopThread());
   assertTrue(Thread.currentThread().getName().startsWith(poolName + "-"));
   fut.complete();
  }, onSuccess(v -> {
   vertx.undeploy(context.deploymentID());
  }));
 }
}, new DeploymentOptions().setWorkerPoolName(poolName), onSuccess(v -> {}));

代码示例来源：origin: io.vertx/vertx-core

@Override
 public void start() throws Exception {
  thread.set(Thread.currentThread());
  assertTrue(Context.isOnVertxThread());
  assertTrue(Context.isOnWorkerThread());
  assertFalse(Context.isOnEventLoopThread());
  assertTrue(Thread.currentThread().getName().startsWith(poolName + "-"));
  context.runOnContext(v -> {
   vertx.undeploy(context.deploymentID());
  });
 }
}, new DeploymentOptions().setWorker(true).setWorkerPoolName(poolName), onSuccess(deployment::set));

代码示例来源：origin: io.vertx/vertx-core

@Override
 public void stop() throws Exception {
  assertTrue(Context.isOnVertxThread());
  assertTrue(Context.isOnWorkerThread());
  assertFalse(Context.isOnEventLoopThread());
 }
};

代码示例来源：origin: io.vertx/vertx-core

@Override
 public void stop() throws Exception {
  assertTrue(Context.isOnVertxThread());
  assertFalse(Context.isOnWorkerThread());
  assertTrue(Context.isOnEventLoopThread());
 }
};

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testThread() {
 String poolName = TestUtils.randomAlphaString(10);
 WorkerExecutor worker = vertx.createSharedWorkerExecutor(poolName);
 AtomicBoolean onVertxThread = new AtomicBoolean();
 AtomicBoolean onWorkerThread = new AtomicBoolean();
 AtomicBoolean onEventLoopThread = new AtomicBoolean();
 AtomicReference<String> threadName = new AtomicReference<>();
 worker.executeBlocking(fut -> {
  onVertxThread.set(Context.isOnVertxThread());
  onWorkerThread.set(Context.isOnWorkerThread());
  onEventLoopThread.set(Context.isOnEventLoopThread());
  threadName.set(Thread.currentThread().getName());
  fut.complete(null);
 }, ar -> {
  testComplete();
 });
 // Use regular assertions because the thread name does not start with "vert.x-"
 // and it confuses the VertxTestBase asserts
 assertWaitUntil(() -> threadName.get() != null);
 assertTrue(onVertxThread.get());
 assertTrue(onWorkerThread.get());
 assertFalse(onEventLoopThread.get());
 assertTrue(threadName.get().startsWith(poolName + "-"));
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testStandardRightThread() throws Exception {
 assertFalse(Context.isOnVertxThread());
 Verticle verticle = new AbstractVerticle() {
  @Override
  public void start() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
  }
  @Override
  public void stop() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
  }
 };
 vertx.deployVerticle(verticle, onSuccess(res -> {
  assertTrue(Context.isOnVertxThread());
  assertFalse(Context.isOnWorkerThread());
  assertTrue(Context.isOnEventLoopThread());
  vertx.undeploy(res, onSuccess(res2 -> {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
   testComplete();
  }));
 }));
 await();
}

代码示例来源：origin: io.vertx/vertx-core

@Test
public void testMTWorkerRightThread() throws Exception {
 assertFalse(Context.isOnVertxThread());
 Verticle verticle = new AbstractVerticle() {
  @Override
  public void start() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertTrue(Context.isOnWorkerThread());
   assertFalse(Context.isOnEventLoopThread());
  }
  @Override
  public void stop() throws Exception {
   assertTrue(Context.isOnVertxThread());
   assertTrue(Context.isOnWorkerThread());
   assertFalse(Context.isOnEventLoopThread());
  }
 };
 vertx.deployVerticle(verticle, new DeploymentOptions().setWorker(true).setMultiThreaded(true), onSuccess(res -> {
  assertTrue(Context.isOnVertxThread());
  assertFalse(Context.isOnWorkerThread());
  assertTrue(Context.isOnEventLoopThread());
  vertx.undeploy(res, onSuccess(res2 -> {
   assertTrue(Context.isOnVertxThread());
   assertFalse(Context.isOnWorkerThread());
   assertTrue(Context.isOnEventLoopThread());
   testComplete();
  }));
 }));
 await();
}

内容来源于网络，如有侵权，请联系作者删除！

Context

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com