Condition实现一个生产者一个消费者

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock; /**
* 生产消费逻辑
*/
public class MyService { private ReentrantLock lock = new ReentrantLock();
private Condition condition = lock.newCondition();
private boolean hasValue = false; public void set() {
try {
lock.lock();
while (hasValue) {
condition.await();
}
System.out.println("☆");
hasValue = true;
condition.signal();
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
lock.unlock();
}
} public void get() {
try {
lock.lock();
while(!hasValue) {
condition.await();
}
System.out.println("★");
hasValue = false;
condition.signal();
} catch (InterruptedException e) {
e.printStackTrace();
}finally {
lock.unlock();
}
}
}

/**
* 生产者线程
*/
public class MyThreadA extends Thread{
private MyService service; public MyThreadA(MyService service) {
this.service = service;
} @Override
public void run() {
for (int i = 0; i < Integer.MAX_VALUE; i++) {
service.set();
}
}
}

/**
* 消费者线程
*/
public class MyThreadB extends Thread{
private MyService service; public MyThreadB(MyService service) {
this.service = service;
} @Override
public void run() {
for (int i = 0; i < Integer.MAX_VALUE; i++) {
service.get();
}
}
}

/**
* 交替打印测试类
*/
public class Run { public static void main(String[] args) {
MyService service = new MyService(); MyThreadA a = new MyThreadA(service);
a.start();
MyThreadB b = new MyThreadB(service);
b.start();
}
}