Shutdown Grace Period for Worker Pools

[gilday]

When consuming incoming events with a blocking consumer that uses a custom worker thread pool, is it possible to configure the shutdown for that thread pool to allow some grace period before interrupting the worker threads?

Consider this small example:

record Job() {}

@Dependent
class Consumer {

  @ConfigProperty(name = "example.sleep", defaultValue = "20s")
  Duration sleep;

  @Inject Logger logger;

  @Blocking(ordered = false)
  @Incoming("jobs")
  public void consume(Job job) throws InterruptedException {
    Thread.sleep(sleep.toMillis());
    logger.infof("Consumed job {}", job);
  }
}

@Dependent
class Producer {

  @Outgoing("jobs")
  public Multi<Job> jobs() {
    return Multi.createBy().repeating().supplier(Job::new).indefinitely();
  }
}

On shutdown, the threads are always interrupted before they're able to finish the blocking job.