1. ReentrantLock类

ReentrantLock可以实现线程之间同步互斥，类似于synchronized同样的效果。

public class ThreadReentrantLock {public static void main(String[] args) {ThreadA threadA = new ThreadA();for (int i = 0; i < 3; i++) {Thread th = new Thread(threadA);th.setName("Thread" + i);th.start();}}static class ThreadA extends Thread {private Lock lock = new ReentrantLock();public void run() {System.out.println(currentThread().getName() + " run");try {lock.lock();System.out.println(currentThread().getName() + " begin");Thread.sleep(1000);System.out.println(currentThread().getName() + " end");} catch (InterruptedException e) {} finally {lock.unlock();}}}
}

输出

2. Condition实现wait/notify功能

主要方法

await()相当于wait()方法
await(long time, TimeUnit unit)相当于wait(long)方法
signal()相当于notify()方法
signalAll()相当于notifyAll()方法

await()和signal()同样需要在lock.lock()之后调用，否则会报监视器出错。

public class ThreadCondition {public static void main(String[] args) {try {ThreadA threadA = new ThreadA();threadA.start();Thread.sleep(3000);threadA.singal();} catch (InterruptedException e) {}}static class ThreadA extends Thread {private Lock lock = new ReentrantLock();private Condition condition = lock.newCondition();public void run() {         try {lock.lock();System.out.println("ThreadA begin await " + System.currentTimeMillis());condition.await();System.out.println("ThreadA end await " + System.currentTimeMillis());} catch (InterruptedException e) {} finally {lock.unlock();}}public void singal() {lock.lock();System.out.println("ThreadA begin signal " + System.currentTimeMillis());condition.signal();System.out.println("ThreadA end signal " + System.currentTimeMillis());lock.unlock();}}
}

输出

3. ReentrantLock方法

getHoldCount()查询当前线程保持此锁的个数，也就是调用lock()方法的次数。
getQueueLength()返回正等待获取此锁定的线程数。
getWaitQueueLength(Condition condition)返回等待与此锁相关的给定条件Condition的线程数。
hasQueuedThread(Thread thread)查询指定的线程是否正在等待获取此锁。
hasQueuedThreads()查询是否有线程正在等待获取此锁。
hasWaiters(Condition condition)查询是否有线程正在等待与此锁有关的给定条件Condition。
isFair()判断是否是公平锁。
isHeldByCurrentThread()查询当前线程是否保持此锁。
isLocked()查询此锁是否由任意线程保持。
lockInterruptibly()当前线程未被中断，则获取锁定，如果中断则出现异常。
tryLock()仅在当前锁未被另一个线程保持的情况下，才能获得该锁。
tryLock(long timeout, TimeUnit unit)仅在给定等待时间内没有被另一线程保持，且当前线程未被中断，才能获得该锁。

4. ReentrantReadWriteLock读写锁

读写锁有两个锁，一个是读操作相关的锁，称为共享锁。另一个写操作相关的锁，叫排它锁。多个读锁之间不互斥，而读锁与写锁、写锁与写锁之间互斥。

public class ThreadReentrantReadWriteLock {  private ReentrantReadWriteLock lock = new ReentrantReadWriteLock();public void read() {try {lock.readLock().lock();System.out.println(Thread.currentThread().getName()+ " read " + System.currentTimeMillis());Thread.sleep(1000);} catch (InterruptedException e) {} finally {lock.readLock().unlock();}}public void write() {try {lock.writeLock().lock();System.out.println(Thread.currentThread().getName()+ " write " + System.currentTimeMillis());Thread.sleep(1000);} catch (InterruptedException e) {         } finally {lock.writeLock().unlock();}}static class WriteThread extends Thread {private ThreadReentrantReadWriteLock service;public WriteThread(ThreadReentrantReadWriteLock service) {this.service = service;}public void run() {service.write();}}static class ReadThread extends Thread {private ThreadReentrantReadWriteLock service;public ReadThread(ThreadReentrantReadWriteLock service) {this.service = service;}public void run() {service.read();}}
}

调用两个读操作，两者几乎同时运行

public static void main(String[] args) {ThreadReentrantReadWriteLock service = new ThreadReentrantReadWriteLock();ReadThread readThread1 = new ReadThread(service);readThread1.setName("ReadThread1");readThread1.start();ReadThread readThread2 = new ReadThread(service);readThread2.setName("ReadThread2");readThread2.start();
}

输出

调用一个读、一个写操作，同一时间只允许一种操作

public static void main(String[] args) {ThreadReentrantReadWriteLock service = new ThreadReentrantReadWriteLock();WriteThread writeThread = new WriteThread(service);writeThread.setName("WriteThread");writeThread.start();ReadThread readThread = new ReadThread(service);readThread.setName("ReadThread");readThread.start();
}

输出

相关文章
Java wait和notify方法
Java Thread.join方法
Java Thread.sleep方法
Java Thread.Interrupt方法
Java Lock对象

Java Lock对象相关推荐

java lock 对象_Java并发编程锁系列之ReentrantLock对象总结
Java并发编程锁系列之ReentrantLock对象总结在Java并发编程中,根据不同维度来区分锁的话,锁可以分为十五种.ReentranckLock就是其中的多个分类. 本文主要内容:重入锁理解 ...
Java:使用synchronized和Lock对象获取对象锁
在并发环境下,解决共享资源冲突问题时,可以考虑使用锁机制. 1.对象的锁所有对象都自动含有单一的锁. JVM负责跟踪对象被加锁的次数.如果一个对象被解锁,其计数变为0.在任务(线程)第一次给对象加锁 ...
Java多线程编程-（5）-使用Lock对象实现同步以及线程间通信
前几篇: Java多线程编程-(1)-线程安全和锁Synchronized概念 Java多线程编程-(2)-可重入锁以及Synchronized的其他基本特性 Java多线程编程-(3)-线程本地Th ...
java static 对象加锁_java安全编码指南之:lock和同步的正确使用
简介在java多线程环境中,lock和同步是我们一定会使用到的功能.那么在java中编写lock和同步相关的代码之后,需要注意哪些问题呢?一起来看看吧. 使用private final object ...
java lock代码写法_java Lock接口详解及实例代码
java lock接口 java.util.concurrent.locks 接口lock public interface loce loce实现提供了比使用synchronized方法和语句可获 ...
[Java] [Lock] [Synchronized VS ReentrantLock]
Overview java编写多线程程序时,为了保证线程安全,需要对数据进行同步,经常用到的两种同步方式就是synchronized和重入锁ReentrantLock. 相似点都是加锁方式都是阻塞 ...
使用synchronized和Lock对象获取对象锁
Java:使用synchronized和Lock对象获取对象锁下面使用ReentrantLock这个锁来实现加锁功能: package com.tch.test.concurrent;import ...
类锁 synchronized对象锁和 Lock对象锁
在并发环境下,解决共享资源冲突问题时,可以考虑使用锁机制. 对象锁所有对象都自动含有单一的锁. JVM负责跟踪对象被加锁的次数.如果一个对象被解锁,其计数变为0.在任务(线程)第一次给对象加锁的时候 ...
Java的对象监视器和Condition监视器概念以及对比
详细介绍了Java对象监视器的概念以及API方法,包括JDK1.5提供的Condition监视器对比. 文章目录 1 对象监视器 1.1 方法 1.2 特点 2 Condition 监视器 2.1 O ...

Java Lock对象

1. ReentrantLock类

2. Condition实现wait/notify功能

3. ReentrantLock方法

4. ReentrantReadWriteLock读写锁

Java Lock对象相关推荐

最新文章

热门文章