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

Question

У меня есть два потока на моем уровне модели данных, которые работают в «параллельном» и оба вычисляют некоторые значения. У меня есть установка шаблона mvc, поэтому моя модель данных имеет два массива, каждый из которых отвечает за значения, генерируемые из каждого из моих потоков. Как я могу сказать, что мои массивы имеют новые данные без блокировки основного интерфейса?

Мои темы предназначены для проезда по таймеру раз в х секунду и производятся по одному целым числам. Каждый из них должен быть добавлен в массив, и при добавлении представление должно получить уведомление через шаблон наблюдателя для обновления экрана в соответствии с обновленными значениями двух массивов. Это должно происходить без блокировки основной нити. Таким образом, я не могу действительно делать (true) или задавать значение futureValue для каждого потока, поскольку это заставит мой u ждать до тех пор, пока потоки не будут выполнены. Что я могу сделать?

Answer 1

Вы всегда будете:

• Продлить класс массива, содержащий результаты и перезаписать add метод
• Помещенный в add в конце кода сообщить UI-нить
• Чтобы синхронизировать обновления, вы можете использовать ExecutorService только с одним потоком, который вы получите с Executors.newSingleThreadExecutor(). В этом вам submit() код для информирования UI-Thread.
• Ваше исполнение должно быть частью WorkerThread и обрабатываться в doInBackground
• В методе done() обновить интерфейс пользователя (done() выполняется на диспетчерский потока событий Свинг)

для получения дополнительной информации смотрите здесь Threads and Swing

Answer 2

Это похоже на довольно сложный подход. Вот мое:

• Создать blocking queue
• избавиться от массивов и имеют каждая нить поставить свои результаты в очереди
• Start рабочий поток, который ждет элементов в очереди
• Использование SwingUtilities.invokeLater() в рабочем потоке для обновления пользовательского интерфейса.