Блог

Пожалуйста, посоветуйте наилучший подход для решения следующих задач:

У меня есть класс Java следующим образом:

 @Service
public class ServiceAImpl {

    private final Set<String> someSet = new HashSet<>();
    private final List<Record> someList = new ArrayList<>();
    private final Map<String, String> someMap = new HashMap<>();

   //Loads XML as a document
   public Optional<Document> readXML(Document xmlDoc){

   }

   //reads the root node and triggers the recursive extraction of the XML data
   public List<Record> extractRootNodeAndTriggersRecursive(){
       extractXMLRecursively(elt);

   }

   //recursively read hierarchical data in the XML
   public SomeObject extractXMLRecursively(Element elt){

   }

   public SomeObject createReportFromTheMapOrList(){

   }

}
 

Я знаю, что члены экземпляра (или список / карты) не являются потокобезопасными.

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

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

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

Кто-нибудь сталкивался с этим сценарием?

Любые идеи, советы или ссылки будут оценены.

Спасибо.

Вы можете использовать ReentrantLock :

 import java.util.concurrent.locks.ReentrantLock;

@Service
public class ServiceAImpl {

    private final Set<String> setNoDuplicateLabelsAllowed = new HashSet<>();
    private final Set<String> someSet = new HashSet<>();

    private final ReentrantLock lock = new ReentrantLock();

   //Loads XML as a document
   public Optional<Document> readXML(Document xmlDoc){
       lock.lock();
       try {
           // modify your collections safely here
       } finally {
           lock.unlock();
       }
   }

   //reads the root node and triggers the recursive extraction of the XML data
   public List<Record> extractRootNodeAndTriggersRecursive(){
       lock.lock();
       try {
           // modify your collections safely here
       } finally {
           lock.unlock();
       }
   }

   //recursively read hierarchical data in the XML
   public SomeObject extractXMLRecursively(Element elt){
       lock.lock();
       try {
           // same here, etc.
       } finally {
           lock.unlock();
       }
   }

 

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