多線程（四）多線程之間的通信

 

 一.環境

  idea

二.多線程之間如何通信，什麼是多線程之間的通信

2.1舉例

多線程模擬生成者消費者，需求生產者生產一條數據，消費者消費一條，交替執行

建立數據載體（實體類）

public class UserInfo implements Serializable {

    private  String username;
    private  String usersex;
}

View Code

 

建立生產者

public class InputThread implements Runnable {
    UserInfo userInfo=new UserInfo();
    //用來作向數據載體中放數據
    public InputThread(UserInfo userInfo){
        this.userInfo=userInfo;
    }
    public void run() {
        int count=0;
        while (true){
            if(count==0){
                userInfo.setUsername("小明");
                userInfo.setUsersex("男");
            }else if (count==1){
                userInfo.setUsername("小紅");
                userInfo.setUsersex("女");
            }
            count=(count+1)%2;
        }

    }
}

View Code

 

建立消費者

public class OutputThread implements Runnable {

    UserInfo userInfo=new UserInfo();

    public OutputThread( UserInfo userInfo){
        this.userInfo=userInfo;
    }

    public void run() {
        while (true){
            if(userInfo!=null){
                System.out.println("userName:"+userInfo.getUsername()+",userSex:"+userInfo.getUsersex());
            }
        }

    }
}

View Code

 

建立測試類

public static void main(String[] args) {
        UserInfo userInfo=new UserInfo();
        OutputThread outputThread=new OutputThread(userInfo);
        InputThread inputThread=new InputThread(userInfo);
        Thread t1=new Thread(outputThread);
        Thread t2=new Thread(inputThread);
        t1.start();
        t2.start();
    }

View Code

 

結果

 

很顯然出現了線程安全問題

修改代碼

 

 數據不亂了，可是還不是咱們想要的結果

2.2wait、notify、notifyAll()方法

修改上述代碼

 

 

 

 

 

 

 

 運行結果