}

if(args length > 1) { // Необязательный аргумент int p = new Integer(args[l]); pause = p > -1 ? p : pause;

}

new HorseRace(nHorses, pause);

}

} ///;-

Для объекта CyclicBarrier можно задать «барьерное действие» — объект Runnable, автоматически запускаемый при обнулении счетчика (еще одно отличие CyclicBarrier от CountdownLatch). В нашем примере барьерное действие определяется в виде безымянного класса, передаваемого конструктору CyclicBarrier.

Я попытался сделать так, чтобы каждый объект лошади отображал себя, но порядок отображения зависел от диспетчера задач. Благодаря CyclicBarrier каждая лошадь делает то, что ей необходимо для продвижения вперед, а затем ожидает у барьера перемещения всех остальных лошадей. Когда все лошади переместятся, CyclicBarrier автоматически вызывает «барьерную» задачу Runnable, чтобы отобразить всех лошадей по порядку вместе с барьером. Как только все задачи пройдут барьер, последний автоматически становится готовым для следующего захода.

DelayQueue

Класс представляет неограниченную блокирующую очередь объектов, реализующих интерфейс Delayed. Объект может быть извлечен из очереди только после истечения задержки. Очередь сортируется таким образом, что объект в начале очереди обладает наибольшим сроком истечения задержки. Если задержка ни у одного объекта не истекла, начального элемента нет, и вызов poll() возвращает null (из-за этого в очередь не могут помещаться элементы null).

В следующем примере объекты, реализующие Delayed, сами являются задачами, a DelayedTaskContainer берет задачу с наибольшей просроченной задержкой и запускает ее. Таким образом, DelayQueue является разновидностью приоритетной очереди.

//• concurrency/DelayQueueDemo java import java util concurrent *; import java util *.

import static java util concurrent TimeUnit *, import static net mindview.util Print *;

class DelayedTask implements Runnable, Delayed { private static int counter = 0; private final int id = counter++, private final int delta; private final long trigger; protected static List sequence =

new ArrayList(), public DelayedTask(int delaylnMilliseconds) { delta = delaylnMilliseconds, trigger = System nanoTimeO +

NANOSECONDS.convert(delta. MILLISECONDS). sequence add(this),

}

public long getDelay(TimeUnit unit) { return unit.convert(

trigger - System.nanoTime(), NANOSECONDS),

}

public int compareTo(Delayed arg) {

DelayedTask that = (DelayedTask)arg, if(trigger < that.trigger) return -1; if(trigger > that.trigger) return 1, return 0;

}

public void run() { printnb(this + " "), } public String toStringO {

return String.format("[£l$-4d]\ delta) + " Task " + id;

}

public String summaryО {

return "(" + id + + delta + ")";

}

public static class EndSentinel extends DelayedTask { private ExecutorService exec; public EndSentinel(int delay. ExecutorService e) { super(delay), exec = e;

}

public void runO {

for(DelayedTask pt . sequence) {

printnb(pt.summary() + " ");

}

printO;

print (this + " вызывает shutdownNowO"); exec.shutdownNowO;

}

}

}

class DelayedTaskConsumer implements Runnable { private DelayQueue q, public DelayedTaskConsumer(DelayQueue q) { this.q = q;