本文整理了Java中com.obsidiandynamics.worker.WorkerThreadBuilder.build()
方法的一些代码示例,展示了WorkerThreadBuilder.build()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WorkerThreadBuilder.build()
方法的具体详情如下:
包路径:com.obsidiandynamics.worker.WorkerThreadBuilder
类名称:WorkerThreadBuilder
方法名:build
暂无
代码示例来源:origin: com.obsidiandynamics.fulcrum/fulcrum-worker
public WorkerThread buildAndStart() {
final WorkerThread thread = build();
thread.start();
return thread;
}
}
代码示例来源:origin: com.obsidiandynamics.fulcrum/fulcrum-scheduler
public TaskScheduler(String threadName) {
executor = WorkerThread.builder()
.withOptions(new WorkerOptions().daemon().withName(threadName))
.onCycle(this::cycle)
.build();
}
代码示例来源:origin: com.obsidiandynamics.hazelq/hazelq-elect
public Election(ElectionConfig config, IMap<String, byte[]> leases) {
this.config = config;
final Retry retry = new Retry()
.withExceptionClass(HazelcastException.class)
.withAttempts(Integer.MAX_VALUE)
.withBackoff(100)
.withFaultHandler(config.getZlg()::w)
.withErrorHandler(config.getZlg()::e);
this.leases = new RetryableMap<>(retry, leases);
registry = new Registry();
scavengerThread = WorkerThread.builder()
.withOptions(new WorkerOptions().daemon().withName(Election.class, "scavenger"))
.onCycle(this::scavegerCycle)
.build();
}
代码示例来源:origin: com.obsidiandynamics.meteor/meteor-elect
public Election(ElectionConfig config, IMap<String, byte[]> leases) {
this.config = config;
final Retry retry = new Retry()
.withExceptionMatcher(isA(HazelcastException.class))
.withAttempts(Integer.MAX_VALUE)
.withBackoff(100)
.withFaultHandler(config.getZlg()::w)
.withErrorHandler(config.getZlg()::e);
this.leases = new RetryableMap<>(retry, leases);
registry = new Registry();
scavengerThread = WorkerThread.builder()
.withOptions(new WorkerOptions().daemon().withName(Election.class, "scavenger"))
.onCycle(this::scavegerCycle)
.build();
}
内容来源于网络,如有侵权,请联系作者删除!