0

Приветсвую, как можно реализовать очередь потоков, чтоб они не играли в перегонки кто первый возьмет монитор, а шли строга по очереди по мере прогрева?

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

2
  • 2
    При такой постановке задачи потоки не нужны, поскольку они не дадут строгой очередности. Здесь будет достаточно Queue
    – kami
    4 фев 2021 в 7:10
  • @kami в дальнейшем, я хочу попытаться реализовать, что полоса неактивна какое-то время, но самолеты начали прогрев и как только полоса открылась, они встали в очередь в том порядке в котором прогрелись, как тут без потоков?
    – Saintka
    4 фев 2021 в 7:16

3 ответа 3

3

Можно сделать честную очередь на локе

 static class Band  {
        public final String name;
        private final Lock lock = new ReentrantLock(true); // <-- FAIR LOCK

        Band(String name) {this.name = name;}

        private boolean tryLock() {return lock.tryLock();}

        private void unlock() {lock.unlock();}

    }

Но я присоединяюсь к совету @kami - сделай лучше очередь событий. См. PriorityQueue


Простой пример с очередью полос

Это проще, чем очередь событий. Но в целом, если делать сложную логику, то лучше делать очередь событий.

public class Airport {
    private final BlockingDeque<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() {
        Band result = bands.take(); // Будет ждать, пока полоса на освободится, поэтому внешний цикл и Thread.sleep больше не нужен
        System.out.println("Полоса " + result.name + " зарезервированна ");
        return result;
    }

    public void releaseBand(@NotNull Band band) {
        bands.add(band);
    }

static class Band  {
        public final String name;
        // отдельный лок на полосу больше не нужен
        // private final Lock lock = new ReentrantLock();

        Band(String name) {this.name = name;}


    }
 ....

9
  • протестил, оно не работает) они как взлетали в рандомном порядке, так и взлетают)
    – Saintka
    7 фев 2021 в 8:38
  • Это из-за Thread.sleep(1000). Переделай на очереди. 7 фев 2021 в 14:48
  • я вот бьюсь с этими очередями какой день и не понимаю, куда их вставлять, я сделал очередь в main, и добавил в эту очередь все объекты, а что дальше делать не пойму
    – Saintka
    7 фев 2021 в 15:18
  • Например, в аэропорту замени список полос на блокирующую очередь полос (new ArrayBlockingQueue(bandCount, true). Соответственно, tryLockedBand больше не будет итерироваться по списку, а будет просто забирать полосу из очереди, а если очередь пустая, то блокироваться и ждать (queue.take). Когда самолёт взлетел, он будет класть полосу обратно в очередь. 7 фев 2021 в 21:07
  • И, кстати, д.б. не band, а runway en.wikipedia.org/wiki/Runway 7 фев 2021 в 21:22
1

ЛИБО) можете использовать синхронизаторы из пакета concurrent

0

Используй после theard.start

  Theard.join()

Пока не выполнится, следующий не запустится

1
  • Я использую join planes.forEach(plane -> { plane.join }
    – Saintka
    8 фев 2021 в 2:55

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge that you have read and understand our privacy policy and code of conduct.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.