1

Суть такая. Есть задача scheduleAtFixedRate который получает некий список файлов, необходимых для загрузки, помещаются они в список ArrayList<countersFeedsItems>

private void startDemons(){
    Timer timer = new Timer(true);
    System.out.println("TimerTask начал выполнение");
    timer.scheduleAtFixedRate(new MyTimerTask() {
        @Override
        public void run() {
            countersFeedsItems = new ViewModel().getCountersFeed();
            System.out.println("запрошен список getCountersFeed()");
                          //дальнейшая необходимая реализация
        }
    }, 10 * 1000, 360*10 * 1000); //10 секунд (10 * 1000 миллисекунд)
    //задание task планируется к выполнению через период в миллисекундах, переданный в параметре delay.
    //Затем задание повторяется повторно периодически - каждые period миллисекунд
}

В списке может быть, к примеру 70 значений-ссылок на файлы.
На ум приходит только Queue? Но из этого списка обрабатывать нужно пачками, не более 10 штук (одновременно).

И далее, тоже проблема. Скорее всего, Очередь нужно положить в некий цикл(?), который будет "ждать" момента, когда в очередь будет < 10.
При этом, все 10 заданий обрабатываются параллельно (у меня через Kotlin-корутины).

Соответственно, для начала как-то пометить задачу, что она находится в процессе (чтобы не начать ее повторное выполнение). Если задача завершилась с ошибкой (файл не скачался/недоступен), то вернуть эту задачу опять в очередь.
Если файл скачался, удалить его из очереди. В тот момент, когда задача из очереди удалена, в очередь добавляется новая ссылка на файл.

Кто-нибудь может помочь, как сделать тот самый некий "цикл" который будет следить за количеством и "ожиданием"? Хотя бы какие методы для этого возможны?

1 ответ 1

1

Для решения вашей задачи идеально подходит интерфейс ExecutorService. Экземпляр этого интерфейса занимается тем, что параллельно выполняет данные ему (Runnable) задания.

Создать экземпляр ExecutorService выполняющий не более чем 10 задач одновременно можно вызвав Executors.newFixedThreadPool(10).

Для добавления задания у ExecutorService есть метод submit.

ExecutorService не завершает работу сам, так как даже после того как все задания будут выполнены, он останется в ожидании новых. А чтобы все-таки завершить его работу, можно поступить следующим образом. Сначала вызвать метод shutdown, чтобы показать что новые задания больше не будут поступать, а затем вызвать метод awaitTermination с нужным временем ожидания, который (если успеет) завершит работу ExecutorService после выполнения всех оставшихся задач.

2
  • И очень советую создавать Runnable через лямбды: () -> { ваш код; }
    – Egor Malko
    12 июн 2021 в 21:03
  • Согласен, хоть и во времена корутин решение выглядит немного олдскульно :), но отлично подходит для такого типа задач. 13 июн 2021 в 19:26

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

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