Форум программистов, компьютерный форум, киберфорум
Java SE (J2SE)
Войти
Регистрация
Восстановить пароль
Блоги Сообщество Поиск Заказать работу  
 
 Аватар для StepFather322
365 / 252 / 113
Регистрация: 07.10.2017
Сообщений: 1,330

Executor service порядок начала выполнения тасков

25.01.2021, 22:23. Показов 1827. Ответов 0
Метки нет (Все метки)

Студворк — интернет-сервис помощи студентам
Есть ExecutorService в виде бина на 10 потоков. Есть сервис который его использует(сабмитит в него таски). Есть контроллер который принимает какие то данные для того чтобы создать эти таски. Когда контроллер принимает запрос, он вызывает сервис который сабмитит таски в ExecutorService.
Вопрос: можно ли сделать так, чтобы таски начинали выполнение свое в том же порядке, в каком они были засабмичены?
Пример: контроллер последовательно получает 3 запроса из которых создает 50, 15, 500 тасков. И соотвественно вызывает 3 раза сервис который их сабмитит. Мне нужно быть уверенным, что первые 50 тасков начнут свое выполнение до того как следующие 15 начнут. Я понимаю что в зависимости от таска им может потребоваться разное время на выполнение. Вопрос лишь в том, чтобы они начали выполняться, до того как начнется выполняться хотя бы один из следующих 15. Вот пример на коленке:
Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
public class Main {
 
    public static void main(String[] args) throws InterruptedException {
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        List<Integer> first = new ArrayList<>();
        List<Integer> second = new ArrayList<>();
        fill(first, 0, 3);
        fill(second, 40, 100);
        CompletableFuture.runAsync(() -> wait(executorService, second));
        CompletableFuture.runAsync(() -> wait(executorService, first));
        sleep(500000);
    }
 
    private static void wait(ExecutorService executorService, List<Integer> fromOTo20) {
        List<? extends Future<?>> futures = submitTasks(fromOTo20, executorService);
        Awaitility.await().atMost(15, TimeUnit.MINUTES).until(() -> futures.stream().allMatch(Future::isDone));
        System.out.println(fromOTo20);
    }
 
    private static void fill(List<Integer> fromOTo20, int from, int to) {
        for (int i = from; i < to; i++) {
            fromOTo20.add(i);
        }
    }
 
    public static List<? extends Future<?>> submitTasks(List<Integer> ids, ExecutorService executorService) {
        return ids.stream()
                .map(integer -> executorService.submit(new Task()))
                .collect(Collectors.toList());
    }
 
 
}
Java
1
2
3
4
5
6
7
8
9
public class Task implements Runnable {
 
    @SneakyThrows
    @Override
    public void run() {
 
        Thread.sleep(new Random().nextInt(1500));
    }
}
Пример выше, выводит лист с цифрами от 0 до 2 раньше листа с числами от 40 до 100, хотя второй лист был отправлен на выполнение в executorService раньше.

Добавлено через 16 минут
Я кстати, скорее всего сильно ошибся в реализации примера на коленке. Но суть вопроса все та же
0
IT_Exp
Эксперт
34794 / 4073 / 2104
Регистрация: 17.06.2006
Сообщений: 32,602
Блог
25.01.2021, 22:23
Ответы с готовыми решениями:

Service: перехват начала ввода сообщения
Вроде дошел до того, что требуемое можно реализовать (не знаю проще ли) с помощью service . Чтобы при начале ввода сообщения, например в...

A Windows service with the name MySQL already exists. Please uninstall this service correctly or choose a different name for the new service.
Не знаю что делать дальше

Порядок выполнения
Собственно есть такой код уже с использование when $(&quot;a&quot;).click(function () { if ($('#info_name').is(':visible')) { ...

0
Надоела реклама? Зарегистрируйтесь и она исчезнет полностью.
BasicMan
Эксперт
29316 / 5623 / 2384
Регистрация: 17.02.2009
Сообщений: 30,364
Блог
25.01.2021, 22:23
Помогаю со студенческими работами здесь

Порядок выполнения
Добрый вечер, столкнулся с такой проблемой. Работаю с чартом, который рисует гистограмму. В методе Generate() происходить заполнение...

Порядок выполнения
Всем привет! Столкнулся с такой бедой: надо что бы WebView выполнял JS функции и он это делает, но в какой-то своей последовательности. Я...

Запуск выполнения функции loop с начала
Добрый вечер. Есть ли возможность из произвольного места loop'a пропустить оставшийся в данной итерации код? Пример кода void...

Непонятный порядок выполнения
Хентай! На мышке есть 3 основные кнопки LMB, RMB, MMB. При попытке перетащить предмет с помощью RMB или MMB порядок выполнения следующий:...

Порядок выполнения методов
Как можно установить фиксированный порядок вызова методов класса?


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
1
Ответ Создать тему
Новые блоги и статьи
делаю науч статью по влиянию грибов на сукцессию
anaschu 13.03.2026
прикрепляю статью
SDL3 для Desktop (MinGW): Создаём пустое окно с нуля для 2D-графики на SDL3, Си и C++
8Observer8 10.03.2026
Содержание блога Финальные проекты на Си и на C++: hello-sdl3-c. zip hello-sdl3-cpp. zip Результат:
Установка CMake и MinGW 13.1 для сборки С и C++ приложений из консоли и из Qt Creator в EXE
8Observer8 10.03.2026
Содержание блога MinGW - это коллекция инструментов для сборки приложений в EXE. CMake - это система сборки приложений. Здесь описаны базовые шаги для старта программирования с помощью CMake и. . .
Как дизайн сайта влияет на конверсию: 7 решений, которые реально повышают заявки
Neotwalker 08.03.2026
Многие до сих пор воспринимают дизайн сайта как “красивую оболочку”. На практике всё иначе: дизайн напрямую влияет на то, оставит человек заявку или уйдёт через несколько секунд. Даже если у вас. . .
Модульная разработка через nuget packages
DevAlt 07.03.2026
Сложившийся в . Net-среде способ разработки чаще всего предполагает монорепозиторий в котором находятся все исходники. При создании нового решения, мы просто добавляем нужные проекты и имеем. . .
Модульный подход на примере F#
DevAlt 06.03.2026
В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .
Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование
8Observer8 05.03.2026
Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .
SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D
8Observer8 04.03.2026
Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .
КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin
Copyright ©2000 - 2026, CyberForum.ru