Обработка нескольких запросов одновременно

У меня есть класс обслуживания

    @Path("/")
     public class ABC {
      @Path(/process/{param})
      public String processRequest(@PathParam("param") String param){
        Thread t = new Thread(()->{
         // Do some processing with the param parmeter
          System.out.println("Processing started for -> "+ param);
          //Do many more things
          //DB transactions,etc.
           });
          t.start();
          return "Your request will be processed";
        }
}

Я принимаю какой-то параметр и начинаю обрабатывать его в новом потоке, и в то же время, чтобы он завершил обработку в течение 30 секунд, я разрываю свое соединение с клиентом, подтверждая его, что его запрос будет обработан.

Он работает нормально и до сих пор без проблем. В настоящее время он может обрабатывать более 5k запросов. Проблема начинается, когда одновременно поступает много запросов, может быть, более 50 КБ, поэтому мое приложение создает новый поток для каждого нового запроса, который заставляет приложение выделять много памяти, а также иногда приводит к исчерпанию памяти JVM.

Есть ли другой способ, с помощью которого я могу немедленно начать обработку, не беспокоясь о количестве запросов, и обработать все запросы в течение 30 секунд, а также ограничить количество активных рабочих потоков.

Один из способов, который я нашел, - это реализация «производитель-потребитель», в которой я могу принимать все запросы и одновременно передавать их производителям, а мои потребители забирают запрос и начинают его обрабатывать. Для этой реализации мне нужно указать максимальное количество запросов, которое может быть принятым производителем (Пример: 100000) и ни одним из потребителей, которые могут обработать запрос (Пример: 1000), так что только 1000 потоков активны и обрабатываются один за другим, но проблема с этим подходом заключается в том, что если любой из потребителей (работающих ) thread, если блокируется по какой-то причине и если он не освобожден, то для обработки запроса остаются только оставшиеся разблокированные потоки, а количество входящих запросов в производителях постоянно увеличивается. Только увеличение количества потребителей создает больше рабочего потока, но в то же время может быть много заблокированных потоков, обрабатывающих задачу.

Пожалуйста, дайте мне знать о любом другом подходе, с помощью которого я могу это сделать.

Примечание: весь запрос должен быть обработан в течение 30 секунд, и если это невозможно, то он не соответствует критериям успеха.