fork download

copy

class producer extends Thread {
	Queue queue;
 
	Producer(Queue queue) {
		this.queue = queue;
	}
 
	public void run() {
		int i = 0;
		while(true) {
			queue.add(i++);
		}
	}
}
 
class Consumer extends Thread {
	String str;
	Queue queue;
 
	consumer(String str, Queue queue) {
		this.str = str;
		this.queue = queue;
	}
 
	public void run() {
		while(true) {
			System.out.println(str + ": " + queue.remove());
		}
	}
}
 
class Queue {
	private final static int SIZE = 10;
	int array[] = new int[SIZE];
	int r = 0;
	int w = 0;
	int count = 0;
 
	synchronized void add(int i) {
 
		// 待ち行列がいっぱいの場合は待機する
		while (count == SIZE) {
			try {
				wait();
			} catch(InterreptedException ie) {
				ie.printStackTrace();
				System.exit(0);
			}
		}
 
		// 配列にデータを追加して書き込みポインタを更新する
		array[w++] = i;
		if (w >= SIZE) {
			w = 0;
		}
 
		// countカウントを1つ増やす
		++count;
 
		// 待機中のスレッドに通知する
		notifyAll();
	}
 
	synchronized int remove() {
 
		// 待ち行列が空の場合は待機する
		while (count == 0) {
			try {
				wait();
			} catch(InterruptedException ie) {
				ie.printStackTrace();
				System.exit(0);
			}
		}
 
		// 配列からデータを読み取って読み取りポインタを更新する
		int element = array[r++];
		if (r >= SIZE) {
			r = 0;
		}
 
		// countを一つ減らす
		--count;
 
		// 待機中のスレッドに通知する
		notifyAll();
 
		// データを返す
		return element;
	}
}
 
class ProducerConsumers {
	Queue queue = new Queue();
	new Producer(queue).start():
	new Consumer("ConsumerA", queue).start());
	new Consumer("ConsumerB", queue).star2());
	new Consumer("ConsumerC", queue).start());}
 
 
 

Main.java:4: error: invalid method declaration; return type required
	Producer(Queue queue) {
	^
Main.java:20: error: invalid method declaration; return type required
	consumer(String str, Queue queue) {
	^
Main.java:95: error: illegal start of type
	new Producer(queue).start():
	^
Main.java:95: error: ';' expected
	new Producer(queue).start():
	   ^
Main.java:95: error: illegal start of type
	new Producer(queue).start():
	            ^
Main.java:95: error: ';' expected
	new Producer(queue).start():
	                  ^
Main.java:95: error: invalid method declaration; return type required
	new Producer(queue).start():
	                    ^
Main.java:95: error: ';' expected
	new Producer(queue).start():
	                           ^
Main.java:97: error: illegal start of type
	new Consumer("ConsumerB", queue).star2());
	^
Main.java:97: error: ';' expected
	new Consumer("ConsumerB", queue).star2());
	   ^
Main.java:97: error: illegal start of type
	new Consumer("ConsumerB", queue).star2());
	            ^
Main.java:97: error: <identifier> expected
	new Consumer("ConsumerB", queue).star2());
	             ^
Main.java:97: error: ';' expected
	new Consumer("ConsumerB", queue).star2());
	                               ^
Main.java:97: error: invalid method declaration; return type required
	new Consumer("ConsumerB", queue).star2());
	                                 ^
Main.java:97: error: ';' expected
	new Consumer("ConsumerB", queue).star2());
	                                        ^
Main.java:98: error: illegal start of type
	new Consumer("ConsumerC", queue).start());}
	^
Main.java:98: error: ';' expected
	new Consumer("ConsumerC", queue).start());}
	   ^
Main.java:98: error: illegal start of type
	new Consumer("ConsumerC", queue).start());}
	            ^
Main.java:98: error: <identifier> expected
	new Consumer("ConsumerC", queue).start());}
	             ^
Main.java:98: error: ';' expected
	new Consumer("ConsumerC", queue).start());}
	                               ^
Main.java:98: error: invalid method declaration; return type required
	new Consumer("ConsumerC", queue).start());}
	                                 ^
Main.java:98: error: ';' expected
	new Consumer("ConsumerC", queue).start());}
	                                        ^
22 errors

Standard output is empty