スレッド通信

通信による相互排他制御

• wait() : notify()またはnotifyAll()で呼び出されるまで待機します
• wait(long m) : mミリ秒待機、もしくはnotify()などで呼び出されるまで待機します
• wait(long m , long n) : mミリ秒 + nナノ秒、もしくはnotify()などで呼び出されるまで待機します

class Test extends Thread {
	static Neko neko;
	public static void main(String args[]) {
		neko = new Neko();
		new Test().start();
		new Test().start();
	}
	public void run() {
		neko.tell();
	}
}

class Neko {
	int ch = 0;
	synchronized void tell() {
		if (ch < 1) {
			try {
				ch++;
				System.out.println("Kitty on your lap");
				Thread.sleep(1000);
				wait(3000);
				System.out.println("おはようございますご主人様");
			}
			catch (InterruptedException err) {
				System.out.println(err);
			}
		}
		else {
			System.out.println("ひざの上の同居人");
		}
	}
}

class Test extends Thread {
	static Neko neko;
	public static void main(String args[]) {
		neko = new Neko();
		new Test().start();
		new Test().start();
	}
	public void run() {
		neko.tell();
	}
}

class Neko {
	int ch = 0;
	synchronized void tell() {
		if (ch == 0) {
			try {
				ch++;
				System.out.println("wait() メソッドで停止します");
				Thread.sleep(1000);
				wait();
				Thread.sleep(1000);
				System.out.println("待機状態を解除しました");
			}
			catch (InterruptedException err) {
				System.out.println(err);
			}
		}
		else {
			System.out.println("待機を解除します");
			notify();
		}
	}
}

class Test extends Thread {
	static Neko neko;
	public static void main(String args[]) {
		neko = new Neko();
		for(int i = 0 ; i < 5 ; i++) new Test().start();
	}
	public void run() {
		neko.tell();
	}
}

class Neko {
	int ch = 0;
	synchronized void tell() {
		if (ch < 4) {
			try {
				ch++;
				System.out.println("wait() メソッドで停止します");
				Thread.sleep(1000);
				wait();
				Thread.sleep(1000);
				System.out.println("待機状態を解除しました");
			}
			catch (InterruptedException err) {
				System.out.println(err);
			}
		}
		else {
			System.out.println("notifyAll() で待機を解除します");
			notifyAll();
		}
	}
}