Эккель Брюс
Шрифт:
Управление оранжереей на базе ScheduledExecutor
В главе 10 была представлена система управления гипотетической оранжереей, которая включала (отключала) различные устройства и регулировала их работу. Происходящее можно преобразовать в контекст многозадачности: каждое событие оранжереи представляет собой задачу, запускаемую в заранее заданное время. Класс ScheduledThreadPoolExecutor предоставляет именно тот сервис, который необходим для решения задачи. Используя методы schedule (однократный запуск задачи) или scheduleAtFixedRate (повторение задачи с постоянным промежутком), мы создаем объекты Runnable, которые должны запуститься в положенное время. Сравните это решение с тем, что приведено в главе 10, и посмотрите, насколько оно упрощается благодаря готовой функциональности ScheduledThreadPoolExecutor:
//: concurrency/GreenhouseScheduler.java
// Новая реализация innerclasses/GreenhouseController.java
// с использованием ScheduledThreadPoolExecutor.
// {Args- 5000}
import java.util.concurrent.*,
import java.util *;
public class GreenhouseScheduler {
private volatile boolean light = false, private volatile boolean water = false; private String thermostat = "Day", public synchronized String getThermostatO { return thermostat,
}
public synchronized void setThermostat(String value) { thermostat = value;
}
ScheduledThreadPoolExecutor scheduler =
new ScheduledThreadPoolExecutor(10), public void schedule(Runnable event, long delay) {
scheduler schedule(event,delay.TimeUnit MILLISECONDS);
}
public void
repeat(Runnable event, long i niti alDel ay, long period) { scheduler scheduleAtFixedRate(
event, i niti alDel ay. period, TimeUnit MILLISECONDS);
}
class LightOn implements Runnable { public void run {
// Сюда помещается аппаратный вызов, выполняющий // физическое включение света System out.printin("Свет включен"); light = true;
}
}
class LightOff implements Runnable { public void run {
// Сюда помещается аппаратный вызов, выполняющий // физическое выключение света. System.out.printin("Свет выключен"), light = false,
}
}
class WaterOn implements Runnable { public void run {
// Здесь размещается код включения // системы полива.
System out printlnC"Полив включен"); water = true;
}
}
class WaterOff implements Runnable { public void run О {
// Здесь размещается код выключения // системы полива
System out.printin("Полив выключен"); water = false,
}
}
class ThermostatNight implements Runnable { public void run {
// Здесь размещается код управления оборудованием System.out.ргШ1п("Включение ночного режима"); setThermostat("Ho4b"), } продолжение &
}
class ThermostatDay implements Runnable { public void run {
// Здесь размещается код управления оборудованием System out рпп^пСВключение дневного режима"), setThermostatCfleHb"),
}
}
class Bell implements Runnable {
public void run { System.out.println("Вам!"), }
}
class Terminate implements Runnable { public void run {
System out ргШ1п("Завершение"); scheduler shutdownNowO;
// Для выполнения этой операции необходимо запустить // отдельную задачу, так как планировщик был отключен-new ThreadО {
public void runО {
for(DataPoint d • data)
System.out.println(d);
}
}. startO;
}
}
// Новая возможность: коллекция данных static class DataPoint {
final Calendar time; final float temperature; final float humidity;
public DataPoint(Calendar d, float temp, float hum) { time = d;
temperature = temp; humidity = hum;
}
public String toStringO {
return time getTimeO + String.formate
" температура: %l$.lf влажность: *2$.2f". temperature, humidity);
}
}
private Calendar lastTime = Calendar.getlnstanceO; { // Регулировка даты до получаса
1astTime.set(Calendar.MINUTE, 30); lastTime set(Calendar.SECOND. 00);
}
private float lastTemp = 65.Of.
private int tempDirecti on = +1;
private float lastHumidity = 50 Of;
private int humidityDirecti on = +1;
private Random rand = new Random(47);
List<DataPoint> data = Collections.synchronizedList(
new ArrayList<DataPoint>0); class CollectData implements Runnable { public void run О {
System.out.println("Сбор данных"); synchronized(GreenhouseScheduler.this) {