package EPON;import java.io.File;import java.io.FileNotFoundException;import java.io.PrintWriter;import java.util.concurrent.Semaphore;public class Simulation {    public static  int ONUNUMBER = 32;    public static final int CYCLENUMBER = 10000;    public static final int WAKEUPTHRESHOLD = -1;    public static final int SLEEPTHRESHOLD = -1;             public static final double RTT = 0;    public static final double GUARDTIME = 1e-6;    public static final double WAKEUPTIME = 20e-4;    public static final double PACKETBIT = 64 * 8;    public static final double RATE = 1e9;        public static double OFFERLOAD;    public static int totalpackets=0;    public static double ARRIVALRATE;    public static int[] report;    public static double[] grant; //grant time    public static int[] totalpacket;     public static Semaphore server_lock;    public static Semaphore[] customer_lock = new Semaphore[ONUNUMBER];        public static PrintWriter out;        public static void main(String[] args) {                try {            out = new PrintWriter(new File("EPON_out.txt"));        } catch (FileNotFoundException e1) {            // TODO Auto-generated catch block            e1.printStackTrace();        }                Thread[] ONUThread;        Thread OLTThread;            for (OFFERLOAD = 0.1; OFFERLOAD < 0.71; OFFERLOAD += 0.1){            totalpackets=0;                        grant = new double[ONUNUMBER];            report = new int[ONUNUMBER];            totalpacket= new int[ONUNUMBER];                   ARRIVALRATE = OFFERLOAD * RATE / (PACKETBIT * ONUNUMBER);            for(int i = 0; i < ONUNUMBER; i++){                customer_lock[i] = new Semaphore(1);                try {                    customer_lock[i].acquire();                }catch (InterruptedException e){}            }            server_lock = new Semaphore(1);            ONUThread = new Thread[ONUNUMBER];            OLTThread = new Thread(new Server(ONUNUMBER,CYCLENUMBER));            OLTThread.start();            for(int i = 0; i < ONUNUMBER; i++){                ONUThread[i] = new Thread(new Customer(i));                ONUThread[i].start();            }            try {                OLTThread.join();            }catch (InterruptedException e){}            for(int i = 0; i < ONUNUMBER; i++){                try {                    ONUThread[i].join();                }catch (InterruptedException e){}            }                    //System.out.println(totalpacket[0]);            for(int jin = 0; jin < ONUNUMBER; jin++){                totalpackets+=totalpacket[jin];            }            //System.out.println(totalpacket[0]);            //System.out.println(totalpackets);            System.out.println((Server.systime-totalpackets*512/(1e9))*1e6/Server.systime);            }                //out.close();    }    public static void set_grant(int i,double t){grant[i] = t;}        public static void set_totalpacket(int i,int t){totalpacket[i] =  t;}   //Server    public static double read_grant(int i){return grant[i];}                    //Customer}