文章详情

短信预约-IT技能 免费直播动态提醒

请输入下面的图形验证码

提交验证

短信预约提醒成功

Java多线程的内置锁与显示锁介绍

2023-06-17 04:23

关注

这篇文章主要讲解了“Java多线程的内置锁与显示锁介绍”,文中的讲解内容简单清晰,易于学习与理解,下面请大家跟着小编的思路慢慢深入,一起来研究和学习“Java多线程的内置锁与显示锁介绍”吧!

Synchronized

内置锁获得锁和释放锁是隐式的,进入synchronized修饰的代码就获得锁,走出相应的代码就释放锁。

synchronized(list){ //获得锁    list.append(); list.count();  }//释放锁

通信

与Synchronized配套使用的通信方法通常有wait(),notify()。

wait()方法会立即释放当前锁,并进入等待状态,等待到相应的notify并重新获得锁过后才能继续执行;notify()不会立刻立刻释放锁,必须要等notify()所在线程执行完synchronized块中的所有代码才会释放。用如下代码来进行验证:

public static void main(String[] args){    List list = new LinkedList();     Thread r = new Thread(new ReadList(list));     Thread w = new Thread(new WriteList(list));     r.start();     w.start(); }class ReadList implements Runnable{    private List list;    public ReadList(List list){ this.list = list; }      @Override    public void run(){         System.out.println("ReadList begin at "+System.currentTimeMillis());         synchronized (list){            try {                 Thread.sleep(1000);                 System.out.println("list.wait() begin at "+System.currentTimeMillis());                list.wait();                 System.out.println("list.wait() end at "+System.currentTimeMillis());             } catch (InterruptedException e) {                 e.printStackTrace();             }         }         System.out.println("ReadList end at "+System.currentTimeMillis());      } }class WriteList implements Runnable{    private List list;    public WriteList(List list){ this.list = list; }      @Override    public void run(){         System.out.println("WriteList begin at "+System.currentTimeMillis());         synchronized (list){             System.out.println("get lock at "+System.currentTimeMillis());            list.notify();             System.out.println("list.notify() at "+System.currentTimeMillis());            try {                 Thread.sleep(2000);             } catch (InterruptedException e) {                 e.printStackTrace();             }             System.out.println("get out of block at "+System.currentTimeMillis());         }         System.out.println("WriteList end at "+System.currentTimeMillis());      } }

运行结果

ReadList begin at 1493650526582WriteList begin at 1493650526582list.wait() begin at 1493650527584get lock at 1493650527584list.notify() at 1493650527584get out of block at 1493650529584WriteList end at 1493650529584list.wait() end at 1493650529584ReadList end at 1493650529584

可见读线程开始运行,开始wait过后,写线程才获得锁;写线程走出同步块而不是notify过后,读线程才wait结束,亦即获得锁。所以notify不会释放锁,wait会释放锁。值得一提的是,notifyall()会通知等待队列中的所有线程。

编码

编码模式比较简单,单一,不必显示的获得锁,释放锁,能降低因粗心忘记释放锁的错误。使用模式如下:

synchronized(object){  }

灵活性

内置锁在进入同步块时,采取的是***等待的策略,一旦开始等待,就既不能中断也不能取消,容易产生饥饿与死锁的问题

在线程调用notify方法时,会随机选择相应对象的等待队列的一个线程将其唤醒,而不是按照FIFO的方式,如果有强烈的公平性要求,比如FIFO就无法满足

性能

Synchronized在JDK1.5及之前性能(主要指吞吐率)比较差,扩展性也不如ReentrantLock。但是JDK1.6以后,修改了管理内置锁的算法,使得Synchronized和标准的ReentrantLock性能差别不大。

ReentrantLock

ReentrantLock是显示锁,需要显示进行 lock 以及 unlock 操作。

通信

与ReentrantLock搭配的通行方式是Condition,如下:

private Lock lock = new ReentrantLock();  private Condition condition = lock.newCondition();  condition.await();//this.wait(); condition.signal();//this.notify(); condition.signalAll();//this.notifyAll();

Condition是被绑定到Lock上的,必须使用lock.newCondition()才能创建一个Condition。从上面的代码可以看出,Synchronized能实现的通信方式,Condition都可以实现,功能类似的代码写在同一行中。而Condition的优秀之处在于它可以为多个线程间建立不同的Condition,比如对象的读/写Condition,队列的空/满Condition,在JDK源码中的ArrayBlockingQueue中就使用了这个特性:

 public ArrayBlockingQueue(int capacity, boolean fair) {    if (capacity <= 0)        throw new IllegalArgumentException();    this.items = new Object[capacity];    lock = new ReentrantLock(fair);     notEmpty = lock.newCondition();     notFull =  lock.newCondition(); }public void put(E e) throws InterruptedException {     checkNotNull(e);     final ReentrantLock lock = this.lock;    lock.lockInterruptibly();    try {        while (count == items.length)             notFull.await();         enqueue(e);     } finally {        lock.unlock();     } }public E take() throws InterruptedException {     final ReentrantLock lock = this.lock;    lock.lockInterruptibly();    try {        while (count == 0)             notEmpty.await();        return dequeue();     } finally {        lock.unlock();     } }private void enqueue(E x) {    // assert lock.getHoldCount() == 1;     // assert items[putIndex] == null;     final Object[] items = this.items;     items[putIndex] = x;    if (++putIndex == items.length)         putIndex = 0;     count++;     notEmpty.signal(); }private E dequeue() {    // assert lock.getHoldCount() == 1;     // assert items[takeIndex] != null;     final Object[] items = this.items;     @SuppressWarnings("unchecked")     E x = (E) items[takeIndex];     items[takeIndex] = null;    if (++takeIndex == items.length)         takeIndex = 0;     count--;    if (itrs != null)         itrs.elementDequeued();     notFull.signal();    return x; }

编码

Lock lock = new ReentrantLock();lock.lock();try{  }finally{    lock.unlock(); }

相比于Synchronized要复杂一些,而且一定要记得在finally中释放锁而不是其他地方,这样才能保证即使出了异常也能释放锁。

灵活性

lock.lockInterruptibly() 可以使得线程在等待锁是支持响应中断;lock.tryLock()  可以使得线程在等待一段时间过后如果还未获得锁就停止等待而非一直等待。有了这两种机制就可以更好的制定获得锁的重试机制,而非盲目一直等待,可以更好的避免饥饿和死锁问题

ReentrantLock可以成为公平锁(非默认的),所谓公平锁就是锁的等待队列的FIFO,不过公平锁会带来性能消耗,如果不是必须的不建议使用。这和CPU对指令进行重排序的理由是相似的,如果强行的按照代码的书写顺序来执行指令,就会浪费许多时钟周期,达不到***利用率

性能

虽然Synchronized和标准的ReentrantLock性能差别不大,但是ReentrantLock还提供了一种非互斥的读写锁,

也就是不强制每次最多只有一个线程能持有锁,它会避免“读/写”冲突,“写/写”冲突,但是不会排除“读/读”冲突,

因为“读/读”并不影响数据的完整性,所以可以多个读线程同时持有锁,这样在读写比较高的情况下,性能会有很大的提升。

下面用两种锁分别实现的线程安全的linkedlist:

class RWLockList {//读写锁      private List list;    private final ReadWriteLock lock = new ReentrantReadWriteLock();    private final Lock readLock = lock.readLock();    private final Lock writeLock = lock.writeLock();    public RWLockList(List list){this.list = list;}    public int get(int k) {         readLock.lock();        try {            return (int)list.get(k);         } finally {             readLock.unlock();         }     }    public void put(int value) {         writeLock.lock();        try {             list.add(value);         } finally {             writeLock.unlock();         }     } }class SyncList  {    private List list;    public SyncList(List list){this.list = list;}    public synchronized int  get(int k){        return (int)list.get(k);     }    public synchronized void put(int value){         list.add(value);     }  }

读写锁测试代码:

List list = new LinkedList();for (int i=0;i<10000;i++){     list.add(i); } RWLockList rwLockList = new RWLockList(list);//初始化数据Thread writer = new Thread(new Runnable() {     @Override    public void run() {        for (int i=0;i<10000;i++){             rwLockList.put(i);         }     } }); Thread reader1 = new Thread(new Runnable() {     @Override    public void run() {        for (int i=0;i<10000;i++){             rwLockList.get(i);         }     } }); Thread reader2 = new Thread(new Runnable() {     @Override    public void run() {        for (int i=0;i<10000;i++){             rwLockList.get(i);         }     } });long begin = System.currentTimeMillis(); writer.start();reader1.start();reader2.start();try {     writer.join();     reader1.join();     reader2.join(); } catch (InterruptedException e) {     e.printStackTrace(); } System.out.println("RWLockList take "+(System.currentTimeMillis()-begin) + "ms");

同步锁测试代码:

List list = new LinkedList();for (int i=0;i<10000;i++){     list.add(i); } SyncList syncList = new SyncList(list);//初始化数据Thread writerS = new Thread(new Runnable() {     @Override    public void run() {        for (int i=0;i<10000;i++){             syncList.put(i);         }     } }); Thread reader1S = new Thread(new Runnable() {     @Override    public void run() {        for (int i=0;i<10000;i++){             syncList.get(i);         }     } }); Thread reader2S = new Thread(new Runnable() {     @Override    public void run() {        for (int i=0;i<10000;i++){             syncList.get(i);         }     } });long begin1 = System.currentTimeMillis(); writerS.start();reader1S.start();reader2S.start();try {     writerS.join();     reader1S.join();     reader2S.join(); } catch (InterruptedException e) {     e.printStackTrace(); } System.out.println("SyncList take "+(System.currentTimeMillis()-begin1) + "ms");

结果:

RWLockList take 248msRWLockList take 255msRWLockList take 249msRWLockList take 224msSyncList take 351msSyncList take 367msSyncList take 315msSyncList take 323ms

可见读写锁的确是优于纯碎的互斥锁

总结

内置锁***优点是简洁易用,显示锁***优点是功能丰富,所以能用内置锁就用内置锁,在内置锁功能不能满足之时在考虑显示锁。

感谢各位的阅读,以上就是“Java多线程的内置锁与显示锁介绍”的内容了,经过本文的学习后,相信大家对Java多线程的内置锁与显示锁介绍这一问题有了更深刻的体会,具体使用情况还需要大家实践验证。这里是编程网,小编将为大家推送更多相关知识点的文章,欢迎关注!

阅读原文内容投诉

免责声明:

① 本站未注明“稿件来源”的信息均来自网络整理。其文字、图片和音视频稿件的所属权归原作者所有。本站收集整理出于非商业性的教育和科研之目的,并不意味着本站赞同其观点或证实其内容的真实性。仅作为临时的测试数据,供内部测试之用。本站并未授权任何人以任何方式主动获取本站任何信息。

② 本站未注明“稿件来源”的临时测试数据将在测试完成后最终做删除处理。有问题或投稿请发送至: 邮箱/279061341@qq.com QQ/279061341

软考中级精品资料免费领

  • 历年真题答案解析
  • 备考技巧名师总结
  • 高频考点精准押题
  • 2024年上半年信息系统项目管理师第二批次真题及答案解析(完整版)

    难度     813人已做
    查看
  • 【考后总结】2024年5月26日信息系统项目管理师第2批次考情分析

    难度     354人已做
    查看
  • 【考后总结】2024年5月25日信息系统项目管理师第1批次考情分析

    难度     318人已做
    查看
  • 2024年上半年软考高项第一、二批次真题考点汇总(完整版)

    难度     435人已做
    查看
  • 2024年上半年系统架构设计师考试综合知识真题

    难度     224人已做
    查看

相关文章

发现更多好内容

猜你喜欢

AI推送时光机
位置:首页-资讯-后端开发
咦!没有更多了?去看看其它编程学习网 内容吧
首页课程
资料下载
问答资讯