VPF::Итератор в отдельной нити. - Форум программистов

AndryG

Дата 31.3.2010, 15:39 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

Доброго.
Имеем класс журнала(Journal), который содержит коллекцию (arraylist) классов-задач(Task)

Один из методов журнала perform(), запускается в отдельной нити, проходит итератором по всем задачам и, для избранных, запускает доп. нити выполнения задач.

Как организовать синхронизированную работу основной нити, которая может изменять журнал и содержащиеся в нем задачи и нити с методом perform() ?
С чего начать? Поголовно во все методы тыкать synchronized ?
Почитал про синхронизацию ... вроде как всё ясно, но на своем примере ... туплю :(

LSD

Дата 31.3.2010, 16:34 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

BlockingQueue спасет отца русской демократии.

--------------------

Disclaimer: this post contains explicit depictions of personal opinion. So, if it sounds sarcastic, don't take it seriously. If it sounds dangerous, do not try this at home or at all. And if it offends you, just don't read it.

AndryG

Дата 31.3.2010, 18:45 (ссылка)

(нет голосов)

Загрузка ...

Новичок

Профиль
Группа: Участник
Сообщений: 11
Регистрация: 10.9.2009

Репутация: нет
Всего: нет

Жаль я не тот самый Отец smile

Блокирующая очередь красиво выглядит в Вашем решении из соседней ветки

Я думаю, что применение очереди для хранения списка заданий в моем планировщике не в тему ... тут никто не входит и выходит ... элементы удаляются из середины списка.

Ещё мысль. Блокирующая очередь защищает от беспредела в её составе, но ведь она не даст мне защиты в изменении содержимого её элементов.

Метод perform() класса Journal

Код

    public void perform() throws TaskManagerException {
        int now = new Time().asInt(); // получаем текуще время с секундах от начала суток (Time не библиотечный класс)
        if (!isEnabled() || prevPerformTime == now){ // откл. или для этого момента времени планировщик уже отработал ранее ...
            return; // ... прерываем метод
        }
        System.out.println("->["+now+"]");
        for (Task task : this) { // итератор класса возвращает итератор поля ArrayList<Task> journal
            if (task.isEnabled() // задание включено и время его между предыдущим запуском метода и "сейчас" ...
                    && task.getTime().asInt() > prevPerformTime
                    && task.getTime().asInt() <= now) { ... значит запускаем задание
                performerFactory.newPerformer(task).start();    System.out.println("RUN!"+task.getName());                
            }
        }
        prevPerformTime = now; // запоминаем момент теперь уже прошлой отработки метода
    }

Именно этот кусок кода я хочу периодически запускать в отдельной нити.
Внешний код, может как изменить кучку упоминаемых здесь полей (int prevPerformTime, boolean enabled, ArrayList<Task> journal) так и "содержимое содержимого" списка (объекты Task) тоже могут быть отредактированы.

Можно нарваться на ConcurrentModificationException ... в данном случае я могу смирится с этим и запустить итератор вновь ... а как быть с изменением элементов списка?

Блин! Я и вопрос задать не могу нормально, ибо не знаю с чего тут начинать думать. Подтолкните меня, пжлст smile

Добавлено через 4 минуты и 29 секунд
Епт. Не могу я рестартовать итератор

Код

        iteratorRestart:
        try{
            for (Task task : this) {
                    //...
            }
        }catch (ConcurrentModificationException e) {
            break iteratorRestart; //изменилось содержимое
        }

так я получу двойную отработку заданий, которые успели проскочить до исключения

Добавлено через 7 минут и 50 секунд
Не отправляйте меня, пжлст, к java.util.concurrent.concurrent* smile

Это сообщение отредактировал(а) AndryG - 31.3.2010, 18:47

LSD

Дата 1.4.2010, 13:38 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

Цитата(AndryG @ 31.3.2010, 19:45

)

Я и вопрос задать не могу нормально, ибо не знаю с чего тут начинать думать. Подтолкните меня, пжлст

С описания задачи, типа:
- есть набор тасков которые надо запускать в определенное время
- у таска есть время запуска, ....
- таск может в любой момент времени быть измененным сторонним процессом
....
как-то так smile

--------------------

ivanovpv

Дата 1.4.2010, 15:28 (ссылка)

(нет голосов)

Загрузка ...

Варвар

Профиль
Группа: Участник
Сообщений: 639
Регистрация: 26.1.2005
Где: Москва

Репутация: 4
Всего: 28

Посмотри в сторону ThreadGroup.

далее, чтобы не вызвать ConcurrentModificationException у тебя есть метод Thread.checkAccess() можно заранее проверять на возможность несинхронизированного доступа и обходить проблемные места.

--------------------

Aut viam inveniam aut faciam

LSD

Дата 2.4.2010, 16:07 (ссылка)

(нет голосов)

Загрузка ...

Leprechaun Software Developer

Профиль
Группа: Модератор
Сообщений: 15718
Регистрация: 24.3.2004
Где: Dublin

Репутация: 210
Всего: 538

А ThreadGroup тут с какого бока может помочь?

--------------------

1 Пользователей читают эту тему (1 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »