public CompletableFuture onWorker()

in harness/src/main/java/org/apache/geode/perftest/jvms/rmi/Controller.java [88:101]

• 13 lines of code
• 3 McCabe index (conditional complexity)

  public CompletableFuture<Void> onWorker(int id, Task task) {
    WorkerRemote worker = workers.get(id);
    if (worker == null) {
      throw new IllegalStateException("Worker number " + id + " is not set");
    }

    return CompletableFuture.runAsync(() -> {
      try {
        worker.execute(task);
      } catch (Exception e) {
        throw new RuntimeException(e);
      }
    }, workerExecutionPool);
  }