-3

Как сделать как на видео:

Видео вопрос

На случай если видео станет недоступно: Есть БД. В ней находятся ID групп. В каждой итерации цикл передаёт ID группы в функцию. Функция начинает выполнять разные условия, запросы, записи в БД. Это занимает N-ое количество времени. И так на каждой итерации.

Такой метод получается последовательный.

Как сделать так что бы сначала прогрузились ID групп, а потом одновременно начались выполнения функций.

11
  • 6
    Внимание на экран! Видео-вопрос! 27 дек 2018 в 9:54
  • @cppquestions Так а что не так то? :) 27 дек 2018 в 9:57
  • Вопрос должен быть в текстовой форме. Опишите свою проблему максимально подробно, желательно с кодом. Если этого будет недостаточно, в качестве дополнительного источника дайте ссылку на видео 27 дек 2018 в 9:58
  • @cppquestions К чему такие ограничения, я решил что на видео про вопрос объясню больше не же ли я бы это делал в текстовом формате. 27 дек 2018 в 9:59
  • 2
    К тому, что вопросы, состоящие из "как сделать X + ссылка", не несут пользы для сообщества. Ссылка станет нерабочей через какое-то время, и вопрос станет абсолютно бесполезным 27 дек 2018 в 10:01

1 ответ 1

3

Очень хотел снять видеоответ, но сейчас, к сожалению, такой возможности нет. Поэтому просто напишу.

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

Шаг 1: Создание очереди задач на выполнение.

Используем базу данных (она уже у вас есть, ничего дополнительно устанавливать не потребуется). Добавляем туда простую таблицу с задачами с полями состояние выполнения, данные для задачи.

Теперь выбираем ID групп и для каждой создаём новую запись в таблице очереди.

Шаг 2: Разгребаем очередь по крону.

Каждые пять секунд запускаем скрипт-воркер (или несколько, с помощью xargs -P, например), который лезет в бд и выбирает одну запись из очереди и помечает её как задача в процессе выполнения. Если свободных задач в очереди нет, скрипт просто завершается. Если удалось получить задачу, скрипт начинает её выполнять (дёргать сторонние апи, что-то писать в базу, обрабатывать картинки и тд). Важно не допустить, чтобы два одновременно запущенных скрипта начали работать по одной задаче. Для этого используйте блокировки вашей бд. По завершении работы над задачей её можно пометить как выполнена или удалить.

Это решение показывает общий принцип работы таких систем. В любом случае вам нужна очередь (в данном случае таблица в бд) и демон, её разгребающий (в данном случае крон).

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