java线程间的通信

class Producter implements Runnable {
Q q;

public Producter(Q q) {
this.q = q;
}

public void run() {
int i = 0;
while (true) {
synchronized (q) {
if (q.bFull)
try {
q.wait();
} catch (Exception e) {
}
if (i == 1) {
q.name = "zhangsan";
try {
Thread.sleep(1);
} catch (Exception e) {
}
q.sex = "male";
} else {
q.name = "lisi";
q.sex = "female";
}
q.bFull = true;
q.notify();
}
i = (i + 1) % 2;
}
}
}

class Consumer implements Runnable {
Q q;

public Consumer(Q q) {
this.q = q;
}

public void run() {
while (true) {
synchronized (q) {
if (!q.bFull)
try {
q.wait();
} catch (Exception e) {
}
System.out.print(q.name);
System.out.println(":" + q.sex);
q.bFull = false;
q.notify();
}
}
}
}

class Q {
String name = "unkonwn";
String sex = "unkonwn";
boolean bFull = false;
}

class ThreadCommunation {
public static void main(String[] args) {
Q q = new Q();
new Thread(new Producter(q)).start();
new Thread(new Consumer(q)).start();
}
}

class Producter implements Runnable {
Q q;

public Producter(Q q) {
this.q = q;
}

public void run() {
int i = 0;
while (true) {
if (i == 0)
q.put("zhangsan", "male");
else
q.put("lisi", "female");
i = (i + 1) % 2;
}
}
}

class Consumer implements Runnable {
Q q;

public Consumer(Q q) {
this.q = q;
}

public void run() {
while (true) {
q.get();
}
}
}

class Q {
private String name = "unkonwn";
private String sex = "unkonwn";
private boolean bFull = false;

public synchronized void put(String name, String sex) {
if (bFull)
try {
wait();
} catch (Exception e) {
}
this.name = name;
try {
Thread.sleep(1);
} catch (Exception e) {
}
this.sex = sex;
bFull = true;
notify();
}

public synchronized void get() {
if (!bFull)
try {
wait();
} catch (Exception e) {
}
System.out.print(name);
System.out.println(":" + sex);
bFull = false;
notify();
}
}

class ThreadCommunation {
public static void main(String[] args) {
Q q = new Q();
new Thread(new Producter(q)).start();
new Thread(new Consumer(q)).start();
}
}