## Batch Jobs via Commandline
[mc](http://github.com/minio/mc) provides 'mc batch' command to create, start and manage submitted jobs.

```
NAME:
  mc batch - manage batch jobs

USAGE:
  mc batch COMMAND [COMMAND FLAGS | -h] [ARGUMENTS...]

COMMANDS:
  generate  generate a new batch job definition
  start     start a new batch job

  @Test
  fun cancelImmediatelyAfterEnqueue() {
    server.enqueue(MockResponse())
    val latch = CountDownLatch(1)
    client =
      client
        .newBuilder()
        .addNetworkInterceptor(
          Interceptor { chain: Interceptor.Chain ->
            try {
              latch.await()
            } catch (e: InterruptedException) {
              throw AssertionError(e)
            }

            }
        };

        CountDownLatch latch = new CountDownLatch(1);

        Deferred<SuggestIndexResponse>.Promise promise = suggester.indexer().indexFromQueryLog(reader, 10, 0);
        promise.then(response -> latch.countDown()).error(error -> latch.countDown());

        assertTrue("Should complete within timeout", latch.await(ASYNC_TIMEOUT_SECONDS, TimeUnit.SECONDS));

            try {
                Thread.sleep(100);
            } catch (InterruptedException ignore) {}
            deferred.resolve(new SuggestResponse("", 0, Collections.emptyList(), 0, null));
        });
        th.start();

        final CountDownLatch latch = new CountDownLatch(1);
        deferred.promise().then(response -> latch.countDown());
        assertTrue(latch.await(5, TimeUnit.SECONDS));
    }

    @Test

Klaus Post <******@****.***> 1759093161 +0200

    protected CrawlerClientFactory crawlerClientFactory;

    /**
     * List of URLs to be deleted, cached for batch processing.
     * All access is synchronized via indexUpdateCallback lock.
     */
    protected List<String> deleteUrlList = new ArrayList<>();

    /** Maximum size of the delete URL cache before batch deletion is triggered. */
    protected int maxDeleteDocumentCacheSize;

        try {
            return ps.execute();
        } catch (final SQLException ex) {
            throw new SQLRuntimeException(ex);
        }
    }

    /**
     * Executes a batch update.
     *
     * @param ps
     *            {@link PreparedStatement}. Must not be {@literal null}.
     * @return An array of the number of rows affected by each command in the batch.
     * @throws SQLRuntimeException

    static void register(Object referent, CountDownLatch latch) {
      references.add(new FinalizableReference(referent, latch));
    }

    final CountDownLatch latch;

    FinalizableReference(Object referent, CountDownLatch latch) {
      super(referent, referenceQueue);
      this.latch = latch;
    }

    @Override
    public void finalizeReferent() {

            CountDownLatch latch = new CountDownLatch(1);

            Thread waiter = new Thread(() -> {
                synchronized (response) {
                    try {
                        if (!response.isReceived()) {
                            response.wait(1000);
                        }
                        latch.countDown();
                    } catch (InterruptedException e) {

                        .status(ApiResult.Status.OK)
                        .result());
    }

    /**
     * Retrieves a specific key match setting by ID.
     *
     * @param id the ID of the key match setting to retrieve
     * @return JSON response containing the key match setting
     */
    // GET /api/admin/keymatch/setting/{id}
    @Execute
    public JsonResponse<ApiResult> get$setting(final String id) {