线程的问题，求解答

0 0

线程的问题，求解答0

下面是我的一个模拟生产者，消费者的线程demo，先给上代码，问题后面描述

package org.hwq.thread;

class Station{
	private int input = -1;
	
	public synchronized void press(int key){
		if( input != -1 ){
			try {
				System.out.println("input！=-1,输入开始等待");
				wait();
				System.out.println("input！=-1,输入被唤醒");
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		input = key;
		System.out.println("输入按键input="+key);
		notify();
	}
	public synchronized int getKey(){
		if(input == -1){
			try {
				System.out.println("input == -1,获取key开始等待");
				wait();
				System.out.println("input == -1,获取key被唤醒");
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
		int key = input;
		System.out.println("取出按键key="+input);
		input = -1;
		notify();
		return key;
	}
}

class Inputor implements Runnable{
	Station station;
	public Inputor(Station station){
		this.station = station;
	}
	public void run(){
		for(int i=0;i<10;i++){
//			System.out.println("点击按键");
			station.press(i);
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
		}
	}
}

class Outputor implements Runnable{
	Station station;
	boolean isRunning = true;
	boolean isStoped = false;;
	public Outputor(Station station){
		this.station = station;
	}
	public void run(){
		while(isRunning){
//			System.out.println("开始获取按键");
			int key = station.getKey();
//			System.out.println("获取到key="+key);
		}
		isStoped = false;
	}
	public void stop(){
		isRunning = false;
		while(!isStoped){
			isRunning = false;
		}
	}
}

public class WaitQueue {
	public static void main(String[] args) {
		Station station = new Station();
		station.notify();
		Inputor inputor = new Inputor(station);
		Outputor outputor = new Outputor(station);
		new Thread(inputor).start();
		new Thread(outputor).start();
//这两句有问题
//		outputor.isRunning = false;
//		station.notifyAll();
		
	}
}

由于取出按键的线程是一直执行的，但是我输入按键线程完成了，所以我想手动关闭取出线程，调用了notifyAll会报错。求解答呀。

线程