本文整理了Java中io.vertx.core.VertxOptions.setInternalBlockingPoolSize()
方法的一些代码示例,展示了VertxOptions.setInternalBlockingPoolSize()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。VertxOptions.setInternalBlockingPoolSize()
方法的具体详情如下:
包路径:io.vertx.core.VertxOptions
类名称:VertxOptions
方法名:setInternalBlockingPoolSize
[英]Set the value of internal blocking pool size
[中]设置内部阻塞池大小的值
代码示例来源:origin: eclipse-vertx/vert.x
case "internalBlockingPoolSize":
if (member.getValue() instanceof Number) {
obj.setInternalBlockingPoolSize(((Number)member.getValue()).intValue());
代码示例来源:origin: io.vertx/vertx-core
case "internalBlockingPoolSize":
if (member.getValue() instanceof Number) {
obj.setInternalBlockingPoolSize(((Number)member.getValue()).intValue());
代码示例来源:origin: eclipse-vertx/vert.x
options.setClusterPublicPort(clusterPublicPort);
options.setEventLoopPoolSize(eventLoopPoolSize);
options.setInternalBlockingPoolSize(internalBlockingPoolSize);
options.setWorkerPoolSize(workerPoolSize);
options.setBlockedThreadCheckInterval(blockedThreadCheckInterval);
代码示例来源:origin: eclipse-vertx/vert.x
assertEquals(options, options.setInternalBlockingPoolSize(rand));
assertEquals(rand, options.getInternalBlockingPoolSize());
try {
options.setInternalBlockingPoolSize(0);
fail("Should throw exception");
} catch (IllegalArgumentException e) {
代码示例来源:origin: EnMasseProject/enmasse
public static Vertx create() {
VertxOptions options = new VertxOptions()
.setWorkerPoolSize(1)
.setInternalBlockingPoolSize(1)
.setEventLoopPoolSize(1);
return Vertx.vertx(options);
}
}
代码示例来源:origin: io.vertx/vertx-core
options.setClusterPublicPort(clusterPublicPort);
options.setEventLoopPoolSize(eventLoopPoolSize);
options.setInternalBlockingPoolSize(internalBlockingPoolSize);
options.setWorkerPoolSize(workerPoolSize);
options.setBlockedThreadCheckInterval(blockedThreadCheckInterval);
代码示例来源:origin: org.amv.vertx/amv-vertx-spring-boot-starter
@ConditionalOnMissingBean(VertxOptions.class)
@Bean
public VertxOptions vertxOptions(EventBusOptions eventBusOptions, MetricsOptions metricsOptions) {
return new VertxOptions()
.setBlockedThreadCheckInterval(properties.getBlockedThreadCheckInterval())
.setEventLoopPoolSize(properties.getEventLoopPoolSize())
.setWorkerPoolSize(properties.getWorkerPoolSize())
.setInternalBlockingPoolSize(properties.getInternalBlockingPoolSize())
.setQuorumSize(properties.getQuorumSize())
.setMaxEventLoopExecuteTime(properties.getMaxEventLoopExecuteTime())
.setHAGroup(properties.getHaGroup())
.setMaxWorkerExecuteTime(properties.getMaxWorkerExecuteTime())
.setWarningExceptionTime(properties.getWarningExceptionTime())
.setFileResolverCachingEnabled(properties.isFileResolverCachingEnabled())
.setHAEnabled(properties.isHaEnabled())
.setEventBusOptions(eventBusOptions)
.setMetricsOptions(metricsOptions);
}
代码示例来源:origin: io.vertx/vertx-core
assertEquals(options, options.setInternalBlockingPoolSize(rand));
assertEquals(rand, options.getInternalBlockingPoolSize());
try {
options.setInternalBlockingPoolSize(0);
fail("Should throw exception");
} catch (IllegalArgumentException e) {
内容来源于网络,如有侵权,请联系作者删除!