jdk1.5多线程Lock接口及Condition接口
2024-10-18 22:35:13
jdk1.5多线程的实现的方式:
jdk1.5之前对锁的操作是隐式的
synchronized(对象) //获取锁
{
} //释放锁
jdk1.5锁的操作是显示的：在包java.util.concurrent.locks中含有多线程实现方式相关的接口和类。
有一个描述锁的Lock接口，也就是把锁面向对象了
使用Lock接口的子类ReentrantLock创建一把锁
Lock lock = new ReentrantLock();
使用Lock替代同步代码块的方式：
1：创建一把锁
2：把之前写在同步代码块中的代码写在lock()和unlock()之间
用lock替代同步代码块之后出现了IllegalMonitorStateException(无效的监视器状态异常)
因为wait()，notifyAll()必须用在同步中，而同步被Lock替代了，所以出现异常
jdk1.5对唤醒等待方法也进行了单独的描述，描述的接口是Condition。
唤醒等待方法必须结合锁来使用，所以使用Lock的newCondition()方法来获取和锁绑定的Condition对象。
下面使用jdk1.5多线程的实现方式，解决一次唤醒所有线程性能低的问题。
import java.util.concurrent.locks.*;
class Product
{
private String name;
private int count;
private boolean flag; //创建一把锁
private Lock lock = new ReentrantLock(); //得到和锁绑定的Condition对象，控制生产线程的唤醒和等待
private Condition pro = lock.newCondition();
//得到和锁绑定的Condition对象，控制消费线程的唤醒和等待
private Condition con = lock.newCondition(); //生产产品的功能
public void produce(String name)
{
lock.lock(); //获取锁
try
{
while (flag)
{
try{pro.await();}catch (InterruptedException e){e.printStackTrace();}
}
this.name = name+"..."+count;
System.out.println(Thread.currentThread().getName()+"***生产了***"+this.name);
count++;
flag = true;
con.signal();
}
finally //为了保证锁必须被释放掉，使用try{...}finally{...}
{
lock.unlock(); //释放锁
}
} //消费产品的功能
public void consume()
{
lock.lock();
try
{
while (!flag)
{
try{con.await();}catch (InterruptedException e){e.printStackTrace();}
}
System.out.println(Thread.currentThread().getName()+"---消费了---"+this.name);
flag = false;
pro.signal();
}
finally
{
lock.unlock();
}
}
} //生产任务
class Producer implements Runnable
{
private Product pro;
public Producer(Product pro)
{
this.pro = pro;
}
public void run()
{
while(true)
{
pro.produce("笔记本电脑");
}
}
} //消费任务
class Consumer implements Runnable
{
private Product pro;
public Consumer(Product pro)
{
this.pro = pro;
}
public void run()
{
while(true)
{
pro.consume();
}
}
} class Demo
{
public static void main(String[] args)
{
Product pro = new Product(); Producer producer = new Producer(pro);
Consumer consumer = new Consumer(pro); new Thread(producer,"生产线01").start();
new Thread(consumer,"消费者01").start();
new Thread(producer,"生产线02").start();
new Thread(consumer,"消费者02").start();
}
}
最新文章
- What is Away3D
- [原创]纯CSS3打造的3D翻页翻转特效
- javascript escape()函数和unescape()函数
- Java Collection Framework概述
- lodop打印控件一点记录
- linux中级-JAVA企业级应用TOMCAT实战
- SOA 和webservice 的区别
- QQ互联OAuth
- DDD：建模原语 之 四象图（转载的神文）
- 使用AlarmManager定时更换壁纸----之一
- Ajax请求在IE和Google Chrome中可以响应，在Firefox中无法响应
- Table of Contents - TCP/IP
- 如何把由js生成的内容水平居中？
- WinForm——记住密码
- 在VS2013、VS2015下如何配置DirectX SDK的开发环境
- Java匹马行天下之JavaSE核心技术——Java基础语法
- Scala学习(五)练习
- iptables限制连接数(如sftp) 以及 谨防CC/DDOS攻击的配置 ( connlimit模块)
- javascript多种继承方式(函数式，浅复制，深复制，函数绑定和借用)
- 反射调用 java bean的set和get方法