1

Имеется код многопоточной программы, работающий корректно с использованием системной многопоточности:

 // Main thread
 Thread producer = new Thread(resultDAO);
 Thread consumer = new Thread(resultsLoader);
 producer.start(); // start first added thread
 consumer.start(); // start second added thread
 try {
     consumer.join();
 } catch (InterruptedException e) {
     e.printStackTrace();
 }

Необходимо переделать данный код с использованием java.util.concurrent, т.е. с программной организацией многопоточности. Написал:

 // Main thread
 Thread producer = new Thread(resultDAO);
 Thread consumer = new Thread(resultsLoader);
 ExecutorService threadExecutor = Executors.newCachedThreadPool();
 threadExecutor.execute(producer);
 threadExecutor.execute(consumer);
 threadExecutor.shutdown();
 while (!threadExecutor.isShutdown()) {
     System.out.println("Main THREAD WAIT");
     try {
         threadExecutor.wait(100);
     } catch (InterruptedException e) {

но главный поток продолжает работать при незакончивших работу подпотоках, и затем вступает в конфликт при доступе к БД с подпотоком consumer. Что я делаю не так? Как в java.util.concurrent сделать аналог join()?

2
  • Надо бы обезопасить доступ к БД, а не стараться уйти от возможности конфликта потоков.
    – Gorets
    3 мая 2012 в 7:13
  • Согласен, если ориентироваться на реальное приложение, но пока вопрос именно в этом - как остановить основной поток до полного выполнения подпотоков?
    – rvm
    3 мая 2012 в 8:41

2 ответа 2

3

Я так понимаю, один поток пишет в базу, а второй в это же время пытается прочитать? Если да, то, на мой взгляд, это не правильный подход. Эти действия должны идти последовательно. Если вы хотите приостановить поток который запускает два других (producer, consumer), то можно попробовать так:

while (true) {
  try {
    Thread.sleep(1000);
  } catch (InterruptedException e) {
    e.printStackTrace();
  }
  int active = taskExecutor.getActiveCount();
  if (active == 0) {
    taskExecutor.shutdown();
    return;
  }
}

taskExecutor - это ThreadPoolTaskExecutor;

Класс, который запускается с помощью taskExecutor, должен имплементить Runnable интерфейс. Также он должен анатироваться примерно так: @Scope(value="prototype"). Пример:

@Scope(value="prototype")
public class RunnableService implements Runnable{
        @Override
    public void run() {
        //TODO
    }
}

Запускается таким образом:

RunnableService task = ContextHolder.getBean(RunnableService.class);
taskExecutor.execute(task);
9
  • Первый поток читает данные из файла и через буфферную очередь передается во второй поток, который перегружает данные в БД. Именно для осуществления этой операции мне необходимо приостановить поток MAIN пока не закончат работу подпотоки.
    – rvm
    3 мая 2012 в 18:22
  • если я правильно вас понял, то вариант который я предложил должен вам подойти. Main будет "спать" пока не выполнятся подпотоки. Только одна поправка: если Main должен выполнять что-то еще после выполнения подпотоков, то вместо return пишем код. 4 мая 2012 в 7:27
  • Thread.sleep(1000) как-то некрасиво. Наверное лучше поискать метод ожидания каких-нибудь подходящих событий. IMHO в java.util.concurrent должен быть такой механизм(ы). Надо доку внимательно почитать.
    – avp
    4 мая 2012 в 9:17
  • @avp предлогайте :) 11 мая 2012 в 10:54
  • Сходу в доке увидел метод boolean awaitTermination(long timeout, TimeUnit unit) throws InterruptedException не то ? -- Кстати, .wait(), который Вы используете IMHO наследуется от Object. Он отработает только по .notify() на этот объект (у Вас ExecutorService threadExecutor). А кто этот .notify() вызовет ?
    – avp
    11 мая 2012 в 12:19
1

Правильный ответ:

Thread producer = new Thread(reader);
Thread consumer = new Thread(resultsLoader);
ExecutorService threadExecutor = Executors.newCachedThreadPool();
threadExecutor.execute(producer);
threadExecutor.execute(consumer);
threadExecutor.shutdown();
try {
    threadExecutor.awaitTermination(5, TimeUnit.SECONDS);
}catch (InterruptedException e) {
     e.printStackTrace();
}

Спасибо @avp натолкнул!

2
  • Как это может быть правильным ответом, если вы установили время ожидания в непонятно откуда взявшийся magic number и, ко всему прочему, [засуппрессили InterruptedException?][1] [1]: ibm.com/developerworks/java/library/j-jtp05236/index.html 19 июн 2012 в 21:36
  • Изучайте на здоровье.
    – avp
    19 июн 2012 в 21:38

Ваш ответ

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

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