本文整理了Java中io.vertx.core.Context.isMultiThreadedWorkerContext()
方法的一些代码示例,展示了Context.isMultiThreadedWorkerContext()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Context.isMultiThreadedWorkerContext()
方法的具体详情如下:
包路径:io.vertx.core.Context
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!