0

Столкнулся с такой проблемой: У меня в базе есть список различных слов на одном языке. Я пытаюсь перевести эти слова на несколько других языков.

@Component
public class WordsProcessingSchedule implements Runnable {

    private final ExecutorService executorService = Executors.newFixedThreadPool(Util.wordsProcessingThreads);

    @Autowired
    ApplicationContext context;

    @Autowired
    TranslationRequestRepository translationRequestRepository;

    @Override
    public void run(){
        List<TranslationRequest> translationRequests = translationRequestRepository.getActualWordsRequests();
        int threatQty = translationRequests.size();;
        CountDownLatch latch = new CountDownLatch(threatQty);
        if(threatQty > 0){
            for(int i = 0; i < threatQty; i++) {
                WordsTranslateProcessing wordsTranslateProcessing = context.getBean(WordsTranslateProcessing.class);
                wordsTranslateProcessing.setThreadId(i);
                wordsTranslateProcessing.setCountDownLatch(latch);
                wordsTranslateProcessing.setTranslationRequest(translationRequests.get(i));
                executorService.execute(wordsTranslateProcessing);
            }
            try {
                latch.await();
            } catch (InterruptedException e) {
                System.out.println(e.getMessage());
            }
        }
        else {
            latch.countDown();
        }
    }

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

2 ответа 2

1

Проблема в том, что context.getBean(WordsTranslateProcessing.class) всегда возвращает один и тот же объект, так что вы в цикле постоянно ему меняете значение языка.

Избавьтесь от состояния в WordsTranslateProcessing, т.е. не храните там язык в виде поля, а передавайте его в метод этого класса. Тогда один класс сможет обрабатывать несколько потоков одновременно:

class WordsTranslateProcessing {
   public void translate(TranslationRequest translationRequest, CountDownLatch latch, int threadId) {
     // тут обрабатываем не сохраняя параметры в поля объекта
   }
}


@Component
public class WordsProcessingSchedule implements Runnable {

    private final ExecutorService executorService = Executors.newFixedThreadPool(Util.wordsProcessingThreads);

    @Autowired
    ApplicationContext context;

    @Autowired
    TranslationRequestRepository translationRequestRepository;

    @Autowired
    WordsTranslateProcessing wordsTranslateProcessing;

    @Override
    public void run(){
        ...
        if(threatQty > 0){
            for(int i = 0; i < threatQty; i++) {
                executorService.execute(() -> {
                     wordsTranslateProcessing.translate(
                        translationRequests.get(i), latch, i);
                }
            }
        ...
    }

2
  • Спасибо за ответ. Но у меня класс WordsTranslateProcessing имплементируется от Runable, поэтому, нужно запускать через run(), который не принимает в себя никаких аргументов
    – Artem
    23 дек 2021 в 7:11
  • В ответе я показал, что не нужно реализовывать Runnable и run. Runnable нужен только, если вы собираетесь экземпляры класса запускать используя ExecutorService, а тут это не нужно. Использование context.getBean само по себе плохой признак, состояние в бине - тоже плохо. 23 дек 2021 в 9:50
0

После долгого времени поисков и размышлений, достижения отчаяния и его преодоления ... решил проблему добавлением аннотации @Scope("prototype") на класс треда.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.