ブロッキング処理を呼び出す例3

BlockingSample3.java

private static final Schedulers SCHEDULER =
  Schedulers.newBoundedElastic(Schedulers.DEFAULT_BOUNDED_ELASTIC_SIZE,
                               Schedulers.DEFAULT_BOUNDED_ELASTIC_QUEUESIZE,
                               "my-boundedElestic", 60, true);

@GetMapping("/foo/{id}")
public Mono<ReturnValue> get(ServerWebeExchange exchange, @PathVariable Long id) {
  return Mono.fromCallable(() -> {
    return getValue(id);
  }).subscribeOn(SCHEDULER);
}

ReturnValue getValue(long id) {
  // ブロッキング処理
}