老师帮忙看看哪里错了

慕斯9009508 2017-11-09

源自：Java多线程 5-1 线程间通信

收起

2回答

提问者慕斯9009508 2017-11-09 22:27:18

public class Weather {
    private int temperature;
    private int humidtiy;
    boolean flag=false;
    public int getTemperature() {
        return temperature;
    }
    public void setTemperature(int temperature) {
        this.temperature = temperature;
    }
    public int getHumidtiy() {
        return humidtiy;
    }
    public void setHumidtiy(int humidtiy) {
        this.humidtiy = humidtiy;
    }
    public synchronized void generate(int humodity,int temperature){
        if(!flag){
            System.out.println("生成数据"+this.toString());
            this.setHumidtiy(humidtiy);
            this.setTemperature(temperature);
            flag=true;
        }
    }
    public synchronized void read(){
        if(flag){
            System.out.println("读取数据"+this.toString());     
            flag=false;
        }
    }
    @Override
    public String toString() {
        return "[温度=" + temperature + ", 湿度=" + humidtiy + "]";
    }
     
}
import java.util.Random;
 
public class GenerateWeather implements Runnable {
    Weather weather;
    public GenerateWeather(Weather weather){
        this.weather=weather;
    }
    @Override
    public void run() {
        for(int i=0;i<100;i++){
            int s=(int)(Math.random())*30;
            int t=(int)(Math.random())*40;
            weather.generate(s,t);
            try {
                Thread.currentThread().sleep(5000);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            Thread.currentThread().notifyAll();
        }
         
    }
 
}
 
public class ReadWeather implements Runnable {
    Weather weather;
    public ReadWeather(Weather weather){
        this.weather=weather;
    }
    @Override
    public void run() {
        for(int i=0;i<100;i++){
            weather.read();
            try {
                Thread.currentThread().sleep(10);
            } catch (InterruptedException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
            Thread.currentThread().notifyAll();
        }
         
    }
     
}
package com.java.weather;
 
public class Test {
 
    public static void main(String[] args) {
        Weather weather=new Weather();
        GenerateWeather gweather=new GenerateWeather(weather);
        ReadWeather rweather=new ReadWeather(weather);
        new Thread(gweather).start();
        new Thread(rweather).start();
    }
 
}

收起回答

一叶知秋519 2017-11-09 19:04:48

你好，建议你把全部代码都贴出来，不要截图；另外把报错信息的截图截全一点，方便帮助你解决问题。祝学习愉快~

收起回答

提问者慕斯9009508 #1

老师已经发了，帮忙看一下！谢谢

2017-11-09 22:27:58
好帮手慕珊回复提问者慕斯9009508 #2

notify()或notifyAll()方法是和wait()方法成对使用的，也就是只能唤醒调用wait()方法进行等待的线程，而你的代码中没有wait()方法，所以会出错。wait()和notify()或notifyAll()方法的调用写在weather类里，可以参考一下线程间通信这一节的代码。

2017-11-10 10:32:31