练习题之Wait/Notify

public class PrintABC {
public static void main(String[] args) {
AtomicInteger synObj = new AtomicInteger(0);
Runnable r = new ThreadModel(synObj);
new Thread(r,"A").start();
new Thread(r,"B").start();
new Thread(r,"C").start();
}
}

public class ThreadModel implements Runnable {
public volatile AtomicInteger ato;

public ThreadModel(AtomicInteger ato) {
this.ato = ato;
}

public void run() {
for(int i=0;i<10;i++) {
synchronized(ato) {
if(ato.get()%3==0) {
System.out.println("A);
ato.set(ato.get()+1);
ato.notifyAll();
} else if(ato.get()%3==1) {
System.out.println("B);
ato.set(ato.get()+1);
ato.notifyAll();
} else if(ato.get()%3==2) {
System.out.println("C);
ato.set(ato.get()+1);
ato.notifyAll();
} else {
ato.wait();
}
}
}
}
}

public class printABC {

public static void main(String [] args) {
AtomicInteger ato = new AtomicInteger(0);
ThreadModel modelA = new ThreadModel(ato,"A",0);
ThreadModel modelB = new ThreadModel(ato,"B",0);
ThreadModel modelC = new ThreadModel(ato,"C",0);
new Thread(modelA).start();
new Thread(modelB).start();
new Thread(modelC).start();
}

}

public class ThreadModel {

private AtomicInteger ato;
private String printChar;
private int flag;
private int count = 0;
public ThreadModel(AtomicInteger ato,String printChar,int flag) {
this.ato = ato;
this.printChar = printChar;
this.flag = flag;
}

public void run() {
synchronized(ato) {
while(true) {
if(ato.get()%3==flag) {
System.out.println(printChar);
ato.set(ato.get()+1);
ato.notifyAll();
count++;
if(count==10) {
break;
}
}else {
ato.wait();
}
}
}
}

}