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

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

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

Context.isMultiThreadedWorkerContext介绍

[英]Is the current context a multi-threaded worker context?
[中]当前上下文是多线程工作上下文吗?

代码示例

代码示例来源:origin: io.vertx/vertx-rx-java

/**
 * Is the current context a multi-threaded worker context?
 * @return true if the current context is a multi-threaded worker context, false otherwise
 */
public boolean isMultiThreadedWorkerContext() { 
 boolean ret = delegate.isMultiThreadedWorkerContext();
 return ret;
}

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

@Test
public void testDeployFromTestThread() throws Exception {
 MyVerticle verticle = new MyVerticle();
 vertx.deployVerticle(verticle, ar -> {
  assertDeployment(1, verticle, null, ar);
  assertFalse(verticle.startContext.isMultiThreadedWorkerContext());
  assertFalse(verticle.startContext.isWorkerContext());
  assertTrue(verticle.startContext.isEventLoopContext());
  testComplete();
 });
 await();
}

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

@Test
public void testDeployWorkerWithConfig() throws Exception {
 MyVerticle verticle = new MyVerticle();
 JsonObject conf = generateJSONObject();
 vertx.deployVerticle(verticle, new DeploymentOptions().setConfig(conf).setWorker(true), ar -> {
  assertDeployment(1, verticle, conf, ar);
  assertFalse(verticle.startContext.isMultiThreadedWorkerContext());
  assertTrue(verticle.startContext.isWorkerContext());
  assertFalse(verticle.startContext.isEventLoopContext());
  vertx.undeploy(ar.result(), ar2 -> {
   assertTrue(ar2.succeeded());
   assertEquals(verticle.startContext, verticle.stopContext);
   testComplete();
  });
 });
 await();
}

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

@Test
public void testDeployMultithreadedWorkerWithConfig() throws Exception {
 MyVerticle verticle = new MyVerticle();
 JsonObject conf = generateJSONObject();
 vertx.deployVerticle(verticle, new DeploymentOptions().setConfig(conf).setWorker(true).setMultiThreaded(true), ar -> {
  assertDeployment(1, verticle, conf, ar);
  assertTrue(verticle.startContext.isMultiThreadedWorkerContext());
  assertTrue(verticle.startContext.isWorkerContext());
  assertFalse(verticle.startContext.isEventLoopContext());
  vertx.undeploy(ar.result(), ar2 -> {
   assertTrue(ar2.succeeded());
   assertEquals(verticle.startContext, verticle.stopContext);
   testComplete();
  });
 });
 await();
}

代码示例来源:origin: io.eventuate.client.java/eventuate-client-java-http-stomp

public static Context getContext(Vertx vertx) {
  Context context = vertx.getOrCreateContext();

  if (context.isEventLoopContext()) {
   logger.trace("Context attached to Event Loop");
  } else if (context.isWorkerContext()) {
   logger.trace("Context attached to Worker Thread");
  } else if (context.isMultiThreadedWorkerContext()) {
   logger.trace("Context attached to Worker Thread - multi threaded worker");
  } else if (! Context.isOnVertxThread()) {
   logger.trace("Context not attached to a thread managed by vert.x");
  }
  return context;
 }
}

代码示例来源:origin: eventuate-clients/eventuate-client-java

public static Context getContext(Vertx vertx) {
  Context context = vertx.getOrCreateContext();

  if (context.isEventLoopContext()) {
   logger.trace("Context attached to Event Loop");
  } else if (context.isWorkerContext()) {
   logger.trace("Context attached to Worker Thread");
  } else if (context.isMultiThreadedWorkerContext()) {
   logger.trace("Context attached to Worker Thread - multi threaded worker");
  } else if (! Context.isOnVertxThread()) {
   logger.trace("Context not attached to a thread managed by vert.x");
  }
  return context;
 }
}

代码示例来源:origin: reactiverse/es4x

worker = context.isWorkerContext() || context.isMultiThreadedWorkerContext();

相关文章