visit this link

http://www.java-samples.com/showtutorial.php?tutorialid=306


Rajanikant

Hi friend,


import java.util.Collections;
import java.util.LinkedList;
import java.util.List;

public class Notify extends Object {
private List list;

public Notify() {
list = Collections.synchronizedList(new LinkedList());
}

public String rItem() throws InterruptedException {
synchronized (list) {
while (list.isEmpty()) {
print("wait()");
list.wait();
print("done with wait()");
}
String item = (String) list.remove(0);

return item;
}
}

public void itemInert(String item) {
print("entering");
synchronized (list) {
list.add(item);
print("added: '" + item + "'");

list.notifyAll();
print("notified");
}
print("leaving");
}

private static void print(String msg) {
String name = Thread.currentThread().getName();
System.out.println(name + ": " + msg);
}

public static void main(String[] args) {
final Notify nf = new Notify();

Runnable r1 = new Runnable() {
public void run() {
try {
String item = nf.rItem();
print("returned: '" + item + "'");
} catch (InterruptedException ix) {
print("interrupted!");
} catch (Exception x) {
print("threw an Exception!!!\n" + x);
}
}
};

Runnable r2 = new Runnable() {
public void run() {
nf.itemInert("Hello!");
}
};

try {
Thread thread1 = new Thread(r1, "A");
thread1.start();

Thread.sleep(500);

Thread thread2 = new Thread(r1, "B");
thread2.start();

Thread.sleep(500);

Thread thread3 = new Thread(r2, "C");
thread3.start();

Thread.sleep(1000);

thread1.interrupt();
thread2.interrupt();
} catch (InterruptedException x) {
}
}
}

Thanks