Семафоры

private final int size = 5;
    public RingBuffer ring = new RingBuffer(size);
    public static ConsumerLetters consumer1 = new ConsumerLetters();
    public static ConsumerDigits consumer2 = new ConsumerDigits();
    public static ConsumerSymbols consumer3 = new ConsumerSymbols();
    
    Semaphore _busy = new Semaphore(1);
    Semaphore _empty = new Semaphore(size);
    Semaphore _full = new Semaphore(0);

_sourceText.textProperty().addListener(new ChangeListener<String>(){
            @Override
            public void changed(ObservableValue<? extends String> observable, String oldValue, String newValue) {
                try {
                    System.out.println("_empty = " + _empty.availablePermits());
                    _empty.acquire();
                    System.out.println("_empty = " + _empty.availablePermits());
                    System.out.println("_busy = " + _busy.availablePermits());
                    _busy.acquire();
                    System.out.println("_busy = " + _busy.availablePermits());
                    ring.bufWrite(newValue.substring(newValue.length() - 1));
                    ring.movHead();
                    System.out.println("Producer running...");
                    System.out.println("_busy = " + _busy.availablePermits());
                    _busy.release();
                    System.out.println("_busy = " + _busy.availablePermits());
                    System.out.println("_full = " + _full.availablePermits());
                    _full.release();
                    System.out.println("_full = " + _full.availablePermits());
                } catch (InterruptedException ex) {
                    System.out.println("Error)))");
                }
            }
        });

package parallellab1;
 
import java.util.logging.Level;
import java.util.logging.Logger;
 
public class ConsumerLetters extends Thread {
    
    ParallelLab1 _form = new ParallelLab1();
    String temp;
    
    @Override
    public void run(){
        do{
            try {
                /*Thread.sleep(3000);
                System.out.println(_form._empty.availablePermits());
                System.out.println(_form._busy.availablePermits());
                System.out.println(_form._full.availablePermits());*/
                _form._full.acquire();
                _form._busy.acquire();
                //System.out.println(_form._busy.availablePermits());
                temp = _form.ring.bufRead();
                _form._trigger1.setText(temp);
                System.out.println("Consumer running...");
                _form.ring.movTail();
                _form._busy.release();
                _form._empty.release();
             } catch (InterruptedException ex) {
                 Logger.getLogger(ConsumerLetters.class.getName()).log(Level.SEVERE, null, ex);
                 System.out.println("lol");
             }
        }while(true);
    }    
}

_form._full.acquire();