Синхронное выполнение между методами и слушателем в java

Question

Предполагая, что я должен писать 10 раз последовательно в последовательный порт.

for (int i = 1; i <= 10; i++) { 
    serialPort.writeInt(i); 
// wait until SerialPortEventListener receives something then write again 
    } 

или:

void writeMoreDate(){ 
     serialPort.writeInt(something); 
    // wait until SerialPortEventListener receives something then write again 
     serialPort.writeInt(something; 
    // wait until SerialPortEventListener receives something then write again 
     serialPort.writeInt(something); 
} 

И у меня есть Serial Port Event Listener, что пожары каждый раз, когда я пишу что-то к нему, и называет .map() метод.

@Override 
    public void serialEvent(SerialPortEvent event) { 
     if (event.isRXCHAR() && event.getEventValue() > 0) { 

//when data arrived do something and notify that next method can execute!    
     } 
    } 

Как я могу заставить метод ждать, пока serialEvent не получит что-то?

-Этот как я не обрабатываются этого до сих пор с помощью java.util.concurrent.Semaphore:

экс:

Semaphore semaphore = new Semaphore(MAX_CONCURRENT_THREADS, true); 

     void writeMoreDate(){ 
      Runnable runnable() -> { 
      serialPort.writeInt(something); 
      semaphore.acquire(); 
      serialPort.writeInt(something; 
      semaphore.acquire(); 
      serialPort.writeInt(something); 
      semaphore.acquire(); 
      } 
       new Thread(runnable).start(); 
      } 

и на последовательный СЛУШАТЕЛЬ:

@Override 
    public void serialEvent(SerialPortEvent event) { 
     if (event.isRXCHAR() && event.getEventValue() > 0) { 
       semaphore.release(); 
     } 
    } 

Но я не уверен, что это правильное решение. Благодарю.

Answer 1

Я бы постарался сделать это немного рекурсивно вместо использования цикла for. Что-то вдоль линий:

private int activeIndex = -1; 
private int maxIndex = -1; 

private void write(int currentIndex, int maxIndex){ 
    if(maxIndex < currentIndex) 
     return; 

    activeIndex = currentIndex; 
    maxIndex = maxIndex; 

    serialPort.writeInt(currentIndex); 
} 

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

public void serialEvent(SerialPortEvent event) { 
    if (event.isRXCHAR() && event.getEventValue() > 0) { 
     ..... 

     write(activeIndex + 1, maxIndex); 
    } 
} 

Было бы гораздо чище, если бы вы могли каким-то образом передают текущие/максимальные индексы через SerialPortEvent вместо использования переменных класса для хранения данных, но я недостаточно знаком с этими классами, чтобы узнать, возможно ли это.

Таким образом, из вашего примера, вы можете использовать его с:

write(0, 10);