多线程Lock锁的问题 - 黑马程序员技术交流社区

package heima;
import java.io.PrintStream;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class IntputOutputDome2 {
/**
* @param args
*/
public static void main(String[] args) {
Res2 r = new Res2();
Thread t1 = new Thread(new Input2(r));
Thread t2 = new Thread(new Input2(r));
Thread t3 = new Thread(new Output2(r));
Thread t4 = new Thread(new Output2(r));
t1.start();
t2.start();
t3.start();
t4.start();
}
}
class Res2{
private String name;
private String sex;
private boolean b = false;
private Lock lock = new ReentrantLock();
Condition c1 = lock.newCondition();
Condition c2 = lock.newCondition();
PrintStream out = null;
public void set(String name,String sex){
System.out.println("当前状态："+b);
lock.lock();//上锁
try {
while(b){
c2.await();
System.out.println("生产："+Thread.currentThread().getName()+"进入等待");
}
this.name=name;
this.sex=sex;
System.out.println(Thread.currentThread().getName()+"......生产......"+name+"----"+sex);
b = true;
c1.signal();//唤醒其他线程
} catch (Exception e) {
}
finally{
lock.unlock();//解锁
}
}
public void out(){
System.out.println("out当前状态："+b);
lock.lock();
try {
while(!b){
c1.await();
System.out.println(Thread.currentThread().getName()+"进入等待");
}
System.out.println(Thread.currentThread().getName()+"......消费................."+name +"----"+sex);
b = false;
c2.signal();
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
finally{
lock.unlock();
}
}
}
class Input2 implements Runnable{
Res2 r;
public Input2(Res2 r){
this.r=r;
}
public void run() {
int x = 0;
while(true){
if(x==0){
r.set("张三", "男");
}
else{
r.set("李四", "女");
}
x = (x+1)%2;
}
}
}
class Output2 implements Runnable{
Res2 r;
public Output2(Res2 r){
this.r=r;
}
public void run() {
while(true){
r.out();
}
}
}

复制代码