Блог

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

 class Job {
  private Lock lock;
  
  // Constructor, getters, setters, etc. removed to stay short
  
  public boolean execute (int maxWaitTime) {
    if (lock.tryLock(maxWaitTime, TimeUnit.MILISECONDS)) {
      try {
        // do some lengthy job under the lock
      } finally {
        lock.unlock();
      }
    return true;
    }
  else return false;
  }
}
 

Теперь предположим, что у меня есть список этих заданий:

 List<Job> jobs = ... ;
 

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

Через некоторое время, скажем, через 10 секунд, если все задания все еще заняты, я сдаюсь и не выполняю ни одного (на самом деле, конечно, в этом случае происходит что-то другое).

Во-первых, я придумал это:

 for (Job job: jobs) {
  if (job.execute(10000)) return; // one job has been executed
}
 

А потом понял, что если бы у меня было N рабочих мест, то я мог бы в конечном итоге подождать в общей сложности 10*N несколько секунд вместо всего 10, прежде чем сдаться, на случай, если свободной работы не будет и ни одна не станет доступной в то же время.

Затем я подумал об этом:

 long start = System.currentTimeMillis();
while (true) {
  for (Job job: jobs) {
    if (System.currentTimeMillis() -start > 10000) return; // give up after 10 seconds
    if (job.execute(0)) return; // one job has been executed
  }
 

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

Моя третья попытка:

 for (Job job: jobs) {
  if (job.execute(10000/jobs.size())) return; // one job has been executed
}
 

Теперь я жду не более 10 секунд по желанию. Но это не самое оптимальное решение.
Допустим, у меня есть 10 рабочих мест, 9 — е-бесплатное, в то время как первые 8 остаются на работе. В этом случае я все равно буду бесполезно ждать 8 секунд, прежде чем найду свободный и выполню его.

Можем ли мы сделать лучше ?

В качестве предпочтения я хотел бы стандартное решение Java 11 без внешней зависимости. Класс заданий в моем примере находится под моим контролем, поэтому при необходимости я могу его реорганизовать.

Спасибо вам за ваши ответы.

Что вам нужно, так это попытаться получить блокировку в течение 10 секунд из N разных потоков. Если вам это удастся, поднимите флаг (вам нужно сделать это потокобезопасно), и если флаг уже поднят, снимите текущую блокировку, в противном случае приступайте к выполнению задачи.

PS: N это количество рабочих мест.