package pressureTest;
import data.LoginData;
import java.util.*;
public class PressureTest {
    //創(chuàng)建記錄線程生成變量
    int threadNum=0;
    //創(chuàng)建線程的總數(shù)變量
    int totalThread=500;
    //創(chuàng)建記錄線程總運(yùn)行時間變量
    long eachThreadCostTimes=0;
    //創(chuàng)建記錄線程完成運(yùn)行變量
    int threadDone=0;
    public static void main(String args[]){
        new PressureTest();
    }
    public PressureTest() {
        //創(chuàng)建等待類
        Object wait=new Object();
        //創(chuàng)建一個線程數(shù)組
        Thread[] threadls=new Thread[totalThread];
        //創(chuàng)建線程
        for(int i=0;i<totalThread;i++){
            threadls[i]=new Thread1(String.valueOf(i),wait,this);
            threadls[i].start();
        }
        while(true){
            //停止運(yùn)行半秒鐘
            try{
                Thread.sleep(500);
            }catch(Exception ex){
                if(threadNum==totalThread){
                    synchronized(wait){
                        //使所有線程同時運(yùn)行
                        wait.notifyAll();
                    }
                    break;
                }
            }
        }
    }
    //每個線程完成運(yùn)行后的方法
    public void threadDone(long eachThreadCostTime){
        //增加線程完成數(shù)
        threadDone++;
        eachThreadCostTimes+=eachThreadCostTime;
        if(threadDone==totalThread){
            System.out.println("線程運(yùn)行的平均時間是"+eachThreadCostTimes/totalThread);
        }
    }
    public void increase(){
        threadNum++;
    }
}
//通過繼承Thread類創(chuàng)建線程
class Thread1 extends Thread{
    PressureTest pressTest=null;
    Object wait=null;
    String name="";
    //線程的構(gòu)造器
    Thread1(String name,Object wait,PressureTest pressTest){
        super(name);
        this.name=name;
        this.wait=wait;
        this.pressTest=pressTest;
    }
    //線程的運(yùn)行方法
    public void run(){
        //記錄線程的增加數(shù)
        pressTest.increase();;
        //使線程停止運(yùn)行,等待其他線程完成創(chuàng)建
        synchronized(wait){
            try {
               //wait.wait();
                System.out.print("線程等待!");
            }
            catch(Exception ex){ex.printStackTrace();}
        }
        //取得線程開始運(yùn)行的時間
        long startTime=System.currentTimeMillis();
        LoginData loginData=new LoginData();
        //設(shè)置管理員的用戶名,密碼和用戶類別
        String name="manager";
        String password="password";
        int state=0;
        //測試用戶,密碼是否通過
        int actualReturn=loginData.checkUser(name,password,state);
        //取得線程結(jié)束的時間
        long endTime=System.currentTimeMillis();
        //計算線程的運(yùn)行時間
        long eachThreadCostTime=endTime-startTime;
        if(actualReturn==0){
            System.out.println("線程"+this.name+"通過檢驗,運(yùn)行的時間是"+eachThreadCostTime+"微秒");
        }else{
            System.err.println("線程"+this.name+"不能通過檢驗,運(yùn)行的時間是"+eachThreadCostTime+"微秒");

        }
        //將線程運(yùn)行的時間傳回主類
        pressTest.threadDone(eachThreadCostTime);
    }
}