com.obsidiandynamics.worker.WorkerThreadBuilder.build()方法的使用及代码示例

x33g5p2x  于2022-02-03 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(114)

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

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();
}

相关文章