Многопоточность

package com.company;
 
import java.util.ArrayList;
import java.util.Collections;
 
/**
 * Второй поток -
 * извлекает числа из первого буфера,
 * начиная с максимального, делит извлечённое число на 2
 * и помещает во второй буфер.
 */
 
public class Extractor1 extends Thread {
    private final int bufferSize = 5;
    private final ArrayList<Double> buffer2 = new ArrayList<>(); //буфер второго потока
    private final ArrayList<Double> bufferGenerator; // буфер первого потока
 
    Extractor1(Generator generator) {
 
        bufferGenerator = generator.getBuffer();
    }
 
    ArrayList<Double> getBuffer() {
        return buffer2;
    }
           
    @Override
    public void run() { 
        double max = 0;
        int count = 0;
        double nn;
        for (int i = 0; i < 30; i++) {
            synchronized (bufferGenerator) {
                while (bufferGenerator.isEmpty()) {
                    try {
                        bufferGenerator.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                max = Collections.max(bufferGenerator);
                bufferGenerator.remove(max);
                bufferGenerator.notifyAll();
            }
 
            synchronized (buffer2) {
                while (buffer2.size() == bufferSize) {
                    try {
                        buffer2.wait();
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                }
                nn =  max / 2;  ///////////////////////////////////////////////////////////////////////////////
                buffer2.add(nn);
                count++;
                System.out.println("Второй  " + count + "    " + nn);
                buffer2.notifyAll();
            }
        }
    }