多线程 同步问题

package work.thread;

import java.util.Objects;

/**
* Created by coolkid on 2014/12/17 0017.
*/

class Ticket implements Runnable{

//票数
private int count = 100;

private Object object = new Object();
private void saleTicket(){
while (true){
synchronized (object){
if (count > 0){
count--;
System.out.println(Thread.currentThread().getName()+" 卖出第 "+(100-count)+" 张票");
}else {
break;
}
}
}

}
@Override
public void run() {
saleTicket();
}
}
public class Thread01 {
public static void main(String[] args) {
Ticket t = new Ticket();
Thread t1 = new Thread(t);
Thread t2 = new Thread(t);
Thread t3 = new Thread(t);
Thread t4 = new Thread(t);

t1.start();
t2.start();
t3.start();
t4.start();
}
}

package work.thread;

/**
* Created by coolkid on 2014/12/17 0017.
*/

class Resource02{
private String name;
private String sex;
private int count = 0;

public synchronized void set(String name,String sex){
while (count>10){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
this.name = name;
this.sex = sex;
count++;
this.notifyAll();
}

public synchronized void out()  {
while (count<1){
try {
this.wait();
} catch (InterruptedException e) {
e.printStackTrace();
}
}
System.out.println(Thread.currentThread().getName()+"\tname = " + name+"\nsex = " + sex);
count--;
this.notifyAll();
}
}

class Input02 implements Runnable{
private Resource02 r;

public Input02(Resource02 r) {
this.r = r;
}

@Override
public void run() {
int x = 0;
while (true){
if (x == 0){
r.set("mike","nan");
}else {
r.set("莉莉","女..........");
}
x = (x+1)%2;
}

}
}

class Output02 implements Runnable{
private Resource02 r;

public Output02(Resource02 r) {
this.r = r;
}

@Override
public void run() {
while (true){
r.out();
}
}
}

public class Thread02 {
public static void main(String[] args) {
//资源
Resource02 r = new Resource02();
//生产者
Input02 i = new Input02(r);
//消费者
Output02 o = new Output02(r);

//执行路径
Thread t1 = new Thread(i);
Thread t2 = new Thread(i);

Thread t3 = new Thread(o);

t1.start();
t2.start();
t3.start();

}
}

package work.thread;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

/**
* Created by coolkid on 2014/12/17 0017.
*/

class Resource02{
private String name;
private String sex;
private int count = 0;

Lock lock = new ReentrantLock();
Condition pro_con = lock.newCondition();
Condition con_con = lock.newCondition();

public void set(String name,String sex){
lock.lock();
try {
while (count>10){
pro_con.await();
}
this.name = name;
this.sex = sex;
count++;
con_con.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}

public void out()  {
lock.lock();
try {
while (count<1){
con_con.await();
}
System.out.println(Thread.currentThread().getName()+"\tname = " + name+"\tsex = " + sex);
count--;
pro_con.signal();
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
lock.unlock();
}
}
}

class Input02 implements Runnable{
private Resource02 r;

public Input02(Resource02 r) {
this.r = r;
}

@Override
public void run() {
int x = 0;
while (true){
if (x == 0){
r.set("mike","nan");
}else {
r.set("莉莉","女..........");
}
x = (x+1)%2;
}

}
}

class Output02 implements Runnable{
private Resource02 r;

public Output02(Resource02 r) {
this.r = r;
}

@Override
public void run() {
while (true){
r.out();
}
}
}

public class Thread02 {
public static void main(String[] args) {
//资源
Resource02 r = new Resource02();
//生产者
Input02 i = new Input02(r);
//消费者
Output02 o = new Output02(r);

//执行路径
Thread t1 = new Thread(i);
Thread t2 = new Thread(i);

Thread t3 = new Thread(o);

t1.start();
t2.start();
t3.start();

}
}