import java.util.ArrayList;
public class Q {
        /**
     * @param args the command line arguments
     */
    public static void main(String[] args) throws InterruptedException {
        // TODO code application logic here
        ArrayList<Integer> buffer = new ArrayList<Integer>();
        FirstThread ob1 = new FirstThread(buffer);
        SecondThread ob2 = new SecondThread(buffer);
        
           // ob1.t1.start();
           // ob2.t2.start();
          //  ob1.t1.join();
          //  ob2.t2.join();
            
      }
}
blic class FirstThread implements Runnable {

private ArrayList<Integer> buffer; //переменная для хранения буфера счислами
Thread t1;
public FirstThread(ArrayList<Integer> buffer){
    this.buffer = buffer;
    t1 = new Thread(this);
   t1.start();
    }
/**
 * Задаче метода - заполнить буфера числами.
 * Если буфер  переполнен, то поток уходит в сон.
 */
public void run(){
    synchronized (buffer){
        int N = 16;//максимальный размер буффера
         for (int i = 1; i <= 100; i++){
            while (buffer.size() > N - 1){
                try{
                    buffer.wait();
                } catch (InterruptedException e){
                    System.out.println("InterruptedException перехвачено");
                }
            }
            java.util.Random random = new java.util.Random();
            int y = random.nextInt(15)+1;
            buffer.add(y);
            System.out.println("+++ В буфер добавлено:" + y + "  Размер буфера:" + buffer.size());
            }
        }
    }
}
public class SecondThread implements Runnable {
    private ArrayList<Integer> buffer; //переменная для хранения буфера с числами
    private double znach = 0;//переменная для хранения максимального значенмя
    private int counter = 0;// счетчик
    Thread t2;
    
    public SecondThread(ArrayList<Integer> buffer){
        this.buffer = buffer;
       t2 = new Thread(this);
       t2.start();
    }
    public void run(){
        while (counter < 100){
            searchMAX();
            synchronized (buffer){
            buffer.notify();
            }
        }
    }
    private void searchMAX(){
        while(buffer.size()==0){
        synchronized (buffer){
            try {
            buffer.wait();
            }catch (InterruptedException e){
            System.out.println(e.getMessage());
            }
          }
        }
        float znach =0;
        synchronized (buffer){
            Collections.sort(buffer);
            znach = buffer.get(buffer.size()-1);
            buffer.remove(buffer.size()-1);
            counter++;
        }
        System.out.println("Максимальное значение" + znach);
    }
}