java生产者/消费者模式实现——一生产者一消费者（操作值）

/**
 * Created by 51304 on 2016/2/28.
 */
public class P {
    private String lock;
    public P(String lock){
        this.lock = lock;
    }

    public void setValue(){
        try{
            synchronized (this.lock){
                if(!ValueObject.value.equals("")){
                    lock.wait();
                }
                String value = System.currentTimeMillis() + "_" +
                        System.nanoTime();
                System.out.println("set value is " + value);
                ValueObject.value = value;
                lock.notify();
            }
        } catch (InterruptedException e){
            e.printStackTrace();
        }
    }
}

import com.sun.org.apache.xpath.internal.SourceTree;

/**
 * Created by 51304 on 2016/2/28.
 */
public class C {
    private String lock;
    public C(String lock){
        this.lock = lock;
    }

    public void getValue(){
        try{
            synchronized (this.lock){
                if(ValueObject.value.equals("")){
                    this.lock.wait();
                }
                System.out.println("get value is " + ValueObject.value);
                ValueObject.value = "";
                this.lock.notify();
            }
        } catch (InterruptedException e){
            e.printStackTrace();
        }
    }
}

/**
 * Created by 51304 on 2016/2/28.
 */
public class ValueObject {
    public static String value = "";
}

/**
 * Created by 51304 on 2016/2/28.
 */
public class ThreadP extends Thread {
    private P p;
    public ThreadP(P p){
        this.p = p;
    }

    @Override
    public void run(){
        while (true){
            p.setValue();
        }
    }
}

/**
 * Created by 51304 on 2016/2/28.
 */
public class ThreadC extends Thread {
    private C c;
    public ThreadC(C c){
        this.c = c;
    }

    @Override
    public void run(){
        while (true){
            c.getValue();
        }
    }
}

/**
 * Created by 51304 on 2016/2/28.
 */
public class TestMain {
    public static void main(String[] args) {
        String lock = new String("");
        P p = new P(lock);
        C c = new C(lock);

        ThreadP threadP =new ThreadP(p);
        ThreadC threadC = new ThreadC(c);

        threadP.start();
        threadC.start();
    }
}