10

Здравствуйте,

Есть задача (Task)

Есть очередь (Queue, блокирующая приоритетная очередь)

Есть менеджер очереди (QueueManager)

Есть обработчик очереди (QueueHandler)

QueueManager - синглтон.

Task, среди прочего, имеет такую характеристику как желаемое время выполнения (desired_at_ts). В этом поле указано время, не раньше которого должна быть выполнена данная задача. Это поле участвует в компараторе, на его основе вычисляется приоритет задачи в очереди.

QueueManager инициализирует очередь, предоставляет методы put()/take() и другие, которые в данный момент не важны.

QueueHandler реализует интерфейс Runnable. QueueHandler в бесконечном цикле обрабатывает очередь Queue.

  • QueueHandler проверяет - наступило ли время, указанное в desired_at_ts
  • если время пришло - выполняет задачу.
  • если время не пришло, QueueHandler должен положить задачу обратно
  • цикл повторяется.

Теперь то, что я хочу узнать:

Если время desired_at_ts не наступило, QueueHandler кладет задачу обратно в очередь. Так как очередь приоритетная - понятно, что эта задача попадет в начало очереди; и при следующем цикле из очереди будет получена она же. Ожидание наступления времени

time = desired_at_ts - now_ts
может быть реализовано методом wait(long ms). Но так как QueueManager может добавить в очередь новую задачу в любой момент, новая задача может иметь desired_at_ts ближе к текущему времени, чем та задача, которая только что была возвращена обратно в очередь. Поток QueueHandler надо пробуждать в тот момент, когда отработает компаратор очереди и задача будет поставлена на свое место по приоритету. Вопросы:

  1. Где должен быть размещен код, пробуждающий поток? В каком методе очереди/компаратора или чего то еще?
  2. Как организовать такую блокировку? Я думаю, удобнее использовать ReentrantLock и Condition от него. Но в этом случае объекты этих классов должны существовать в единственном экземпляре и должны будут передаваться из класса в класс. Это нормально?
  3. Если есть комментарии/критика к описанному мною алгоритму - буду рад обсудить их.
4
  • я бы просто сделал обертку над очередью, которая не выдает элемент, пока не истек await на каком-нибудь синхронизаторе (этот await сбрасывается путем добавления нового элемента в обертку)
    – etki
    10 мая 2016 в 18:19
  • 2
    Посмотрите реализацию j.u.c.DelayQueue в JDK. Там один из ожидающих потоков получает сигнал пробуждения при добавлении, если новый элемент попал в начало очереди, и при выходе из take, если очередь не пуста. Ожидание и пробуждение потоков происходит в коде очереди, поэтому ReentrantLock никуда не передается.
    – zRrr
    10 мая 2016 в 21:02
  • zRrr, а как быть с приоритетом при использовании j.u.c.DelayQueue?
    – jonua
    11 мая 2016 в 6:13
  • 2
    А, в этом случае delay и будет тем самым приоритетом. То, что надо
    – jonua
    11 мая 2016 в 6:17

1 ответ 1

2

Из комментария пользователя @zRrr:

Посмотрите реализацию j.u.c.DelayQueue в JDK. Там один из ожидающих потоков получает сигнал пробуждения при добавлении, если новый элемент попал в начало очереди, и при выходе из take, если очередь не пуста. Ожидание и пробуждение потоков происходит в коде очереди, поэтому ReentrantLock никуда не передается.

Ваш ответ

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

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