Философия Java3
Шрифт:
}
}
public static void main(String[] args) {
int nHorses = 7;
int pause = 200,
if(args.length > 0) { // Необязательный аргумент int n = new Integer(args[0J); nHorses = n > 0 ? n . nHorses,
}
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<DelayedTask> sequence =
new ArrayList<DelayedTask>, 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("[lbl$-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<DelayedTask> q, public DelayedTaskConsumer(DelayQueue<DelayedTask> q) { this.q = q;
public void run { try {
while(IThread interruptedO)
q.takeO.runО; // Выполнение задачи в текущем потоке } catchdnterruptedException е) {
// Приемлемый вариант выхода
}
print("Завершается DelayedTaskConsumer");
public class DelayQueueDemo {
public static void main(String[] args) { Random rand = new Random(47),
ExecutorService exec = Executors newCachedThreadPoolО; DelayQueue<@060>DelayedTask> queue =
new DelayQueue<DelayedTask>; // Очередь заполняется задачами со случайной задержкой-for(int i = 0; i < 20; i++)
queue put(new DelayedTask(rand.nextInt(5000))); // Назначение точки остановки queue.add(new DelayedTask.EndSentinel(5000, exec)); exec.execute(new DelayedTaskConsumer(queue)),
}
} /* Output;
[128 ] Task 11 [200 ] Task 7 [429 ] Task 5 [520 ] Task 18 [555 ] Task 1 [961 ] Task 4 [998 ] Task 16 [1207] Task 9 [1693] Task 2 [1809] Task 14 [1861] Task 3 [2278] Task 15 [3288] Task 10 [3551] Task 12 [4258] Task 0 [4258] Task 19 [4522] Task 8 [4589] Task 13 [4861] Task 17 [4868] Task 6 (0:4258) (1.555) (2:1693) (3-1861) (4.961) (5:429) (6:4868) (7:200) (8:4522) (9:1207) (10:3288) (11:128) (12:3551) (13.4589) (14.1809) (15-2278) (16:998) (17:4861) (18:520) (19:4258) (20:5000) [5000] Task 20 вызывает shutdownNowO Завершается DelayedTaskConsumer *///.-
DelayedTask содержит контейнер List<DelayedTask> с именем sequence, в котором сохраняется порядок создания задач, и мы видим, что сортировка действительно выполняется.
Интерфейс Delayed содержит единственный метод getDelay, который сообщает, сколько времени осталось до истечения задержки или как давно задержка истекла. Метод заставляет нас использовать класс TimeUnit, потому что его аргумент относится именно к этому типу. Впрочем, этот класс очень удобен, поскольку он позволяет легко преобразовывать единицы без каких-либо вычислений. Например, значение delta хранится в миллисекундах, а метод Java SE5 System.nanoTime выдает значение в наносекундах. Чтобы преобразовать значение delta, достаточно указать исходные и итоговые единицы:
NANOSECONDS.convert(delta. MILL ISECONDS);
В getDelay желаемые единицы передаются в аргументе unit. Аргумент используется для преобразования времени задержки во временные единицы, используемые вызывающей стороной.
Для выполнения сортировки интерфейс Delayed также наследует интерфейс Comparable, поэтому необходимо реализовать метод compareToQ для выполнения осмысленных сравнений. Методы toStringO и summary обеспечивают форматирование вывода.
Из выходных данных видно, что порядок создания задач не влияет на порядок их выполнения — вместо этого задачи, как и предполагалось, выполняются в порядке следования задержек.