// OurClientAsyncJob extends scout's ClientAsyncJob by adding some initial data and having a way to handle it at the end of calculation

              List<OurClientAsyncJob> jobs = new ArrayList<>();
              JobGroup jobGroup = new JobGroup("job-group", numImporterThreads, partitions.size());
              int block = 1;
              int blocksTotal = partitions.size();
              for (List<AnotherBusinessBean> partition : partitions) {
                OurClientAsyncJob asyncJob = createAsyncJob(partition), block + "-of-" + blocksTotal);
                asyncJob.setSystem(false);
                asyncJob.setUser(true);
                asyncJob.setJobGroup(jobGroup);
                asyncJob.schedule();
                jobs.add(asyncJob);
                block++;
              }
              try {
                jobGroup.join(0, null);
              } catch (OperationCanceledException | InterruptedException e) {
                LOGT.error("Error creating job groups", e);
                return importResults;
              }

              for (OurClientAsyncJob job : jobs) {
                job.throwOnError();
                job.handleResult();
                }
              }

  public void exampleOfJobBatchExecution() throws Exception {
    //assume we want no more than 10 parallel threads at a time
    int maxParallelThreads = 10;
    IExecutionSemaphore lock = Jobs.newExecutionSemaphore(maxParallelThreads);
    //collect all futures. An alternative would be to give the Jobs an executionHint in the JobInput
    ArrayList<IFuture<String>> futures = new ArrayList<>();
    for (int i = 0; i < 1000; i++) {
      String operationValue = "operation " + i;
      Callable<String> operation = () -> operationValue;
      JobInput input = Jobs
          .newInput()
          .withExecutionSemaphore(lock);
      IFuture<String> f = Jobs.schedule(operation, input);
      futures.add(f);
    }
    //wait until all done and collect results
    List<String> results = futures
        .stream()
        .map(f -> f.awaitDoneAndGet())
        .collect(Collectors.toList());
    //...
  }