【Java】waitとnotifyを利用したコールバックの実現【イベント】

/**
* 共有されるデータクラス。
* メンバのdataが変更されたらreadメソッドのwaitが解除されて最新のdataを返します。
*/
public class SharedObject {
private String data;

public synchronized String read() {
try {
// writeメソッド内でnotifyが呼ばれるまで待機します。
wait();
} catch (InterruptedException e) {
System.out.println(e);
}
// メンバdataを返します。
return data;
}

public synchronized void write(String str) {
// メンバdataを変更します。
data = str;
// readメソッドのwaitを解除します。
notifyAll();
}
}

/**
* SharedObjectテスト用クライアント
* ５秒に一回SharedObject.writeを実行して値を書き換えます。
* 書き換えが行われたタイミングでSharedObjectを監視していたWatchingThreadが
* 変化を検知して画面へメッセージを出力します。
*/
public class Client {

/** 監視対象のオブジェクト */
private SharedObject sharedObject = null;

public static void main(String[] args) {
new Client();
}

public Client() {
sharedObject = new SharedObject();

// 監視スレッドを起動しておきます。
WatchingThread t = new WatchingThread();
t.start();

while (true) {
// 5秒に一回sharedObjectのdataに時間を書き込みます。
try {
Thread.sleep(5000);
} catch (InterruptedException e) {
e.printStackTrace();
}
sharedObject.write("" + System.currentTimeMillis());
}
}

/**
* SharedObjectを監視するスレッド
*/
class WatchingThread extends Thread {
@Override
public void run() {
while (true) {
// sharedObjectのdataが変更されるまでここで待機します。
String changedData = sharedObject.read();
System.out.println("sharedObject.data が変更されました。" + changedData);
}
}
}

}