Приветсвую, как можно реализовать очередь потоков, чтоб они не играли в перегонки кто первый возьмет монитор, а шли строга по очереди по мере прогрева?
public class Airport {
private final BlockingQueue<Band> bands;
Airport(int bandCount) {
this.bands = new ArrayBlockingQueue<>(bandCount, true);
for (int i = 0; i < bandCount; i++) {
bands.add(new Band("Полоса " + i));
}
}
@NotNull
public Band waitForAvailableBand() throws InterruptedException {
Band result = bands.take();
System.out.println("Полоса " + result.name + " зарезервированна ");
return result;
}
public void releaseBand(@NotNull Band band) {
bands.add(band);
}
static class Band {
public final String name;
Band(String name) {this.name = name;}
}
}
public abstract class Plane extends Thread {
public final String name;
private final Airport airport;
private final int delay;
Plane(String name, Airport airport, int delay) {
this.name = name;
this.delay = delay;
this.airport = airport;
}
public int getDelay() {
return delay;
}
public static int rnd(int min, int max) {
max -=min;
return (int) (Math.random() * ++ max) + min;
}
@Override
public void run() {
int time = 1000;
int time2 = 10000;
int timeEver = rnd(time,time2);
Airport.Band band;
try {
System.out.println("Прогрев начался: " + name);
Thread.sleep(timeEver);
System.out.println("Прогрев завершился: " + name + " " + timeEver);
System.out.println("Резервируем полосу для: " + name);
band = airport.waitForAvailableBand();
try {
System.out.println("Взлетаем: " + name + " c полосы " + band.name);
Thread.sleep(getDelay());
System.out.println("Взлетел: " + name);
} finally {
airport.releaseBand(band);
}
} catch (InterruptedException ignored) {}
}
}
public class Main {
public static void main(String[] args) {
Airport airport = new Airport(2);
ArrayList<Plane> planes = new ArrayList<>();
planes.add(new Passenger("1", airport, 5000));
planes.add(new Cargo("2", airport, 10000));
planes.add(new Passenger("3", airport, 5000));
planes.add(new Passenger("4", airport, 5000));
planes.add(new Cargo("5", airport, 10000));
planes.forEach(plane -> {
try {
plane.join();
} catch (InterruptedException exception) {}
});
System.out.println("Программа завершила свою работу");
}
}
Далее идет вывод:
Прогрев начался: 2
Прогрев начался: 1
Прогрев начался: 4
Прогрев начался: 3
Прогрев начался: 5
Прогрев завершился: 1 1763
Резервируем полосу для: 1
Полоса Полоса 0 зарезервированна
Взлетаем: 1 c полосы Полоса 0
Прогрев завершился: 4 2966
Резервируем полосу для: 4
Полоса Полоса 1 зарезервированна
Взлетаем: 4 c полосы Полоса 1
Прогрев завершился: 3 3621
Резервируем полосу для: 3
Прогрев завершился: 5 4445
Резервируем полосу для: 5
Прогрев завершился: 2 6217
Резервируем полосу для: 2
Взлетел: 1
Полоса Полоса 0 зарезервированна
Взлетаем: 3 c полосы Полоса 0
Взлетел: 4
Полоса Полоса 1 зарезервированна
Взлетаем: 5 c полосы Полоса 1
Взлетел: 3
Полоса Полоса 0 зарезервированна
Взлетаем: 2 c полосы Полоса 0
Взлетел: 5
Взлетел: 2
Программа завершила свою работу
В моменте где прогрев завершился: Пассажирский1 и Пассажирский2, взлет происходит Пассажирский1 и грузовой3