Java并发编程中锁的释放

简介: Java并发编程中锁的释放

主动释放锁,是通过什么方法来达到的呢?
如果,我们看过Object类的方法,我们会注意到它有三个奇怪的方法:wait(),notify()和notifyAll()。 它们就是用来释放锁的。
1 线程的状态#
在讲锁的释放前,我们先讲一下线程的三种主要状态:运行、就绪(可运行)、阻塞。当然,除了这个之外,肯定还有初始状态和结束状态,那个就不讨论了。
threestates.png
当我们创建线程之后,还只是进入初始状态,如果我们调用run()方法运行,根本就不会启动新的线程。当调用start()后,可以将线程状态改为可运行状态,然后,由操作系统来决定调用哪个线程。当幸运的被操作系统选中之后,就可以进入真正的运行状态了。当运行当时间片用完,或者调用yield()礼让方法,就会把当前当执行权交出来,进入可运行就绪状态。如果在运行的过程中,有系统IO,如等待输入,弹出确认对话框等,则会使当前线程进入阻塞状态,动弹不得。只有等待用户操作之后,才能往下进行。sleep()方法和join()方法可以可以达到类似的阻塞效果。
morestates.png
然后,我们把对象锁部分的状态也加进来。当我们使用synchronized修饰方法或者代码块时,会获取对象的锁,并进入获取该对象锁的等待池,由操作系统来决定调用哪个线程(非公平锁)。当获取到该对象锁之后,就可以进入可运行状态了。
另外,还有一个对象的wait()方法,可以使线程放弃持有的该对象锁,并进入通知等待状态。当其他线程调用等待线程需要的对象的notify()或者notifyAll()方法时,该线程重新进入获取对象锁的队列中参与锁的获取。
2 wait() notify() 和 notifyAll()#
synchronized获取锁的方法我们已经详细的讲解过了,我们接下来来看一下如何主动释放锁。假设,我们想创建两个线程,让这两个线程,依次做一件事情,而不是同时启动之后,就由操作系统来决定它们的执行顺序,那么,我们该怎么做呢?
那就是首先请求前一个线程的锁,然后,获取自己线程的锁,再释放自己的锁,并通知这个锁对象的等待队列(下一个线程!哎哎,醒醒别睡啦,起来干活啦!),释放前一个线程的锁,并进入等待前一个锁对象的通知队列。
twothreads.png
用代码展示为:
public class SyncDemo implements Runnable {
private String name;
private Object prev;
private Object cur;

public SyncDemo(String name, Object prev, Object cur) {
    this.name = name;
    this.prev = prev;
    this.cur = cur;
}

@Override
public void run() {
    int count = 10;
    while (count > 0) {
        synchronized(prev) {
            synchronized(cur) {
                System.out.println(name);
                count--;
                cur.notify();
            }
            try {
                prev.wait();
            } catch (Exception e) {
                e.printStackTrace();
            }
        }
    }
}

public static void main(String[] args) {
    Object a = new Object();
    Object b = new Object();
    SyncDemo r1 = new SyncDemo("A", b, a);
    SyncDemo r2 = new SyncDemo("B", a, b);

    new Thread(r1).start();
    try {
        Thread.sleep(100);
    } catch (Exception e) {
        e.printStackTrace();
    }
    new Thread(r2).start();
}

}
//代码效果参考:http://www.zidongmutanji.com/zsjx/31939.html

写得更通用一点,支持更多的线程依次执行:
public static void main(String[] args) {
int num = 5;

Object[] locks = new Object[num];
String[] names = {"A", "B", "C", "D", "E"};
SyncDemo[] runnable = new SyncDemo[num];

for (int i = 0; i < num; i++) {
    locks[i] = new Object();
}

for (int i = 0; i < num; i++) {
    runnable[i] = new SyncDemo(names[i], locks[(i - 1 + num) % num] , locks[i]);
}

for (int i = 0; i < num; i++) {
    new Thread(runnable[i]).start();
    try {
        Thread.sleep(100);
    } catch (Exception ex) {
        ex.printStackTrace();
    }
}

}

相关文章
|
1天前
|
Java 网络安全
Java中的Socket编程详解
Java中的Socket编程详解
|
1天前
|
安全 Java 开发者
Java并发编程之深入理解synchronized关键字
【6月更文挑战第26天】在Java并发编程的世界中,synchronized关键字扮演着守护者的角色,它保护着共享资源的完整性。本文将深入探讨synchronized关键字的内部机制、使用方法及其对性能的影响,帮助开发者更好地利用这一工具来构建线程安全的应用。
|
1天前
|
存储 Java API
探索Java中的Lambda表达式:现代编程的瑞士军刀
随着Java 8的推出,Lambda表达式成为了Java编程语言的一大亮点。本篇文章旨在深入探讨Lambda表达式在Java中的应用及其对现代编程实践的影响。文章首先概述Lambda表达式的基本概念和语法结构,随后通过实例分析其在函数式编程接口中的运用,最后讨论Lambda表达式如何优化代码的可读性和简洁性,以及它对Java未来发展方向的潜在影响。
|
1天前
|
监控 Java 调度
Java并发编程:深入理解线程池
【6月更文挑战第26天】在Java并发编程的世界中,线程池是提升应用性能、优化资源管理的关键组件。本文将深入探讨线程池的内部机制,从核心概念到实际应用,揭示如何有效利用线程池来处理并发任务,同时避免常见的陷阱和错误实践。通过实例分析,我们将了解线程池配置的策略和对性能的影响,以及如何监控和维护线程池的健康状况。
7 1
|
22小时前
|
存储 缓存 Java
老程序员分享:Java并发编程:线程池的使用
老程序员分享:Java并发编程:线程池的使用
|
1天前
|
缓存 Java 编译器
必知的技术知识:Java并发编程:volatile关键字解析
必知的技术知识:Java并发编程:volatile关键字解析
|
1天前
|
安全 Java API
《面试专题-----经典高频面试题收集三》解锁 Java 面试的关键:深度解析并发编程基础篇高频经典面试题(第三篇)
《面试专题-----经典高频面试题收集三》解锁 Java 面试的关键:深度解析并发编程基础篇高频经典面试题(第三篇)
5 0
|
1天前
|
安全 Java 开发者
Java并发编程:深入理解synchronized和ReentrantLock
在Java并发编程中,正确使用同步机制是确保线程安全的关键。本文将深入探讨Java内置的两种同步机制——synchronized关键字和ReentrantLock类。我们将通过权威数据、经典理论和实际案例,对比分析它们的性能、用法和适用场景,帮助开发者做出明智的选择。
5 0
|
1天前
|
Java 关系型数据库 MySQL
基于Java少儿编程管理系统设计和实现(源码+LW+调试文档+讲解等)
基于Java少儿编程管理系统设计和实现(源码+LW+调试文档+讲解等)
|
10天前
|
安全 Java 程序员
Java并发编程中的锁机制与优化策略
【6月更文挑战第17天】在Java并发编程的世界中,锁是维护数据一致性和线程安全的关键。本文将深入探讨Java中的锁机制,包括内置锁、显式锁以及读写锁的原理和使用场景。我们将通过实际案例分析锁的优化策略,如减少锁粒度、使用并发容器以及避免死锁的技巧,旨在帮助开发者提升多线程程序的性能和可靠性。