Java Multi threading - Избегайте дублирования обработки запроса

Question

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

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

Answer 1

Если проблема с утечкой памяти является проблемой, обратите внимание на WeakHashMap, чтобы сохранить ваш запрос во время обработки.

Другим решением было бы использовать память, связанную кэш ...

Answer 2

Хорошо, я думаю, что я вроде понимаю, что вы хотите.

Вы можете использовать ConcurrentSkipListSet в качестве очереди. Реализовать свои очереди элементов, как это:

class Element implements Comparable<Element> { 
     //To FIFOnize 
     private static final AtomicLong SEQ = new AtomicLong(); 
     private final long id = SEQ.incrementAndGet(); 

     //Can only be executed once. 
     private final Semaphore execPermission = new Semaphore(1); 


     public int compareTo(Element e){ 
      // If element e1 exists on the queue such that 
      // e.compareTo(e1) == 0, that element will not 
      // be placed on the queue. 
      if(this.equals(e)){ 
       return 0; 
      }else{ 
       //This will enforce FIFO. 
       this.id > e.id ? 1 : (this.id < e.id ? -1 : 0); 
      } 
     } 
     //implement both equals and hashCode 

     public boolean tryAcquire(){ 
      return execPermission.tryAcquire(); 
     } 
} 

Теперь ваши темы должны

while(!Thread.currentThread().isInterrupted()){ 
    //Iterates from head, therefore simulates FIFO 
    for(Element e : queue){ 
      if(e.tryAcquire()){ 
       execute(e); //synchronous 
       queue.remove(e); 
      } 
    } 
} 

Вы можете также использовать блокирующий вариант этого решения (имеет ограниченный SortedSet и пусть рабочие потоки не блокируют, если нет элементы и т. д.).

Answer 3

Не существует неотъемлемой причины, по которой отслеживание запросов в HashMap (или любой другой способ, который вы можете выбрать) приведет к утечке памяти. Все, что необходимо - это способ удаления записей после их обработки.

Это может означать, ваши потоки обработки запроса:

• непосредственно удалить запись;
• обращается к диспетчеру; или
• отметьте запрос обработанным, поэтому , чтобы диспетчер мог удалить записи.