lock类的自带函数newCondtion

陈丽莉

本帖最后由黑马朱超于 2013-3-22 18:34 编辑

/**
jdk 1.5新特性
javase day12-06 生产者消费者
两个生产者，两个消费者，一共四个线程的情况
使用lock替换掉 synchronized;
使用condition替换掉wait和notify；
建立两个condition区分等待和唤醒的不同线程
*/
import java.util.concurrent.locks.*;
class ProducerConsumerLockDemo
{
public static void main(String[] args)
{
Resource r =new Resource();
Producer pro1 = new Producer(r);
Consumer con1 = new Consumer(r);
Thread p1 = new Thread(pro1);
Thread p2 = new Thread(pro1);
Thread c1 = new Thread(con1);
Thread c2 = new Thread(con1);
p1.start();
p2.start();
c1.start();
c2.start();
}
}
class Resource
{
private String name;
private int count =1;
private boolean flag = false;
private Lock lock =new ReentrantLock();
private Condition condition_pro =lock.newCondition();//内嵌的new方法?
private Condition condition_con =lock.newCondition();
public void set(String name) throws InterruptedException
{
lock.lock();
try
{
while(flag)//线程被唤醒时候判断标记,可能造成全部等待
condition_pro.await();
this.name = name+"---"+count++;
System.out.println(Thread.currentThread().getName()+"..生产者.."+this.name);
flag =true;
condition_con.signal();//唤醒该锁的对方等待线程
}
finally
{
lock.unlock();
}
}
public void out() throws InterruptedException
{
lock.lock();
try
{
while(!flag)
condition_con.await();
System.out.println(Thread.currentThread().getName()+"..消费者......"+this.name);
flag =false;
condition_pro.signal();
}
finally
{
lock.unlock();
}
}
}
class Producer implements Runnable
{
private Resource res;
Producer(Resource res)
{
this.res = res;
}
public void run()
{
int x = 0;
while(true)
{
try
{
if(x==0)
res.set("蛋糕");
else
res.set("蛋糕");
x = (x+1)%2;
}
catch(InterruptedException e)
{}
}
}
}
class Consumer implements Runnable
{
private Resource res;
Consumer(Resource res)
{
this.res = res;
}
public void run()
{
while(true)
{
try
{
res.out();
}
catch(InterruptedException e)
{}
}
}
}

复制代码

private Condition condition_pro =lock.newCondition();
使用lock和condition 编码，代码中红色的东西不理解。有谁对lock.newCondition();这个方法有研究过？是lock对象调用的函数返回一个新的condition么？
也是是看new创建类的对象看惯了，看这代码不习惯。呵呵。那这右边的应该不算创建新的对象把。？

罗玉宁 · 罗玉宁

Condition 实例实质上被绑定到一个锁上。要为特定 Lock 实例获得 Condition 实例，就需要调用Lock的newCondition() 方法。Lock是接口我们就使用他的一个ReentrantLock子类来调用newCondition 。
Conditon是接口。其实源代码里面是在 ReentrantLock的内部类中的newCondition方法中new 了一个Condition的子类并返回。
lock.newCondition();是创建一个对象，只不过不是由你创建的而是在源代码中创建的并返回一个Condition对象。
其实这个问题意义不大，想想单例模式不就是直接返回一个对象吗和这个差不多。

李尧 · 李尧

Condition是一个接口,这个方法实际返回的是它的一个实例.
Condition 实例实质上被绑定到一个锁上。要为特定 Lock 实例获得 Condition 实例，就要使用其 newCondition() 方法。
也就是说不让你自己new 而是提供一个方法给你,这个方法返回的是一个Condition的对象.没什么难理解吧.

孙娜 · 孙娜

lock.newCondition();是lock对象，调用newCondition()方法，newCondition()返回一个实例。

黑马朱超 · 黑马朱超

罗玉宁发表于 2013-3-22 03:13
Condition 实例实质上被绑定到一个锁上。要为特定 Lock 实例获得 Condition 实例，就需要调用Lock的newCond ...

恩，就和单例设计模式一样一样的。

刘凯 · 刘凯

这个是问题是 ReentrantLock对象lock调用ReentrantLock中的newCondition()方法，返回一个Condition的一个子类对象。
并且这个Condition的子类对象与这个锁相关联
不过我跟楼上有些不同见解
我不认为这个是单例模式  单例模式返回的始终是同一个对象
而这个 ReentrantLock对象lock每次调用一次newCondition()方法返回的对象是一个新的对象
即
private Condition condition_pro =lock.newCondition();
private Condition condition_con =lock.newCondition();  这两句  condition_pro condition_con 是两个不同的对象  并与lock这个锁相关联

正式因为这个Lock接口能够关联多个Condition的子类对象所以才引入的这个知识点解决不同进程见得等待和唤醒问题
所以说我感觉这个与单例模式并不相同但内部实质还是new了Contion的子类对象并与这个锁相关联

陈丽莉 · 陈丽莉

记得及时处理帖子哦，继续追问，或将分类改成【已解决】~

黑马朱超 · 黑马朱超

刘凯发表于 2013-3-22 12:14
这个是问题是 ReentrantLock对象lock调用ReentrantLock中的newCondition()方法，返回一个Condition的一个子 ...

恩。单例设计模式只能建立一个类的对象，这点有区别，呵呵

帐号		自动登录	找回密码
密码			加入黑马

lock类的自带函数newCondtion

评分

7 个回复

评分

评分

评分

评分

黑马骑士勋章