package lab8multiplethread; public class Consumer extends Thread{ private SharedBuffer V; private String Nom; public Consumer(String Nom,SharedBuffer V){ this.V = V; this.Nom = Nom; } @Override public void run(){ try { sleep(Math.round(Math.random()*1000)); } catch (InterruptedException ex) {} long val = V.consume(); System.out.println("Consumer " + Nom + " reads " + val); } }