标签：lock ReentrantLock 获取 线程 println public
一、基本特性
1. 可重入锁
- 如果一个线程已经获取了一个锁，因为该线程是该锁的主人。当第二次获取这个锁的时候，依然可以获取到该锁
- 不可重入：第二次获取就会造成死锁，部分锁就是这种情况
package com.dreamer.multithread.day01;
import java.util.concurrent.locks.ReentrantLock;
public class Demo01 {
/**
* 1. 同一个线程在执行过程中，多次获取释放同一把锁
* 2. 可以正常获取和释放：锁重入
*/
private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
lock.lock();
try {
System.out.println("主线程第一次获取到锁");
method1();
} finally {
lock.unlock();
}
}
public static void method1() {
lock.lock();
try {
System.out.println("主线程第二次加锁");
method2();
} finally {
lock.unlock();
}
}
public static void method2() {
lock.lock();
try {
System.out.println("主线程第三次加锁");
} finally {
lock.unlock();
}
}
}
2. 可打断锁
- 没有其他线程争夺锁
package com.dreamer.multithread.day01;
import java.util.concurrent.locks.ReentrantLock;
public class Demo02 {
private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
Thread slaveThread = new Thread(() -> {
try {
/**
* 1. 如果其他线程没有争夺这把锁，则正常执行
* 2. 如果其他线程获取了这把锁，则该线程就会进入等待
* 3. 该等待状况可以自己打断
*/
lock.lockInterruptibly();
System.out.println("slave-thread 获取到了锁");
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println("slave-thread 被其他线程打断，无法获取到锁");
return;
}
try {
System.out.println("slave-thread 执行业务逻辑");
} finally {
lock.unlock();
}
});
slaveThread.start();
}
}
- 其他线程先获取锁，执行一段时间后，等待获取锁的线程打断等待
- 避免一个线程死等锁，造成死锁现象
package com.dreamer.multithread.day01;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
public class Demo02 {
private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
Thread slaveThread = new Thread(() -> {
try {
/**
* 1. 如果其他线程没有争夺这把锁，则正常执行
* 2. 如果其他线程获取了这把锁，则该线程就会进入等待
* 3. 该等待状况可以被其他线程打断
*/
lock.lockInterruptibly();
System.out.println("slave-thread 获取到了锁");
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println("slave-thread 被其他线程打断，无法获取到锁");
return;
}
try {
System.out.println("slave-thread 执行业务逻辑");
} finally {
lock.unlock();
}
});
/*其他线程先获取到了锁*/
lock.lock();
slaveThread.start();
try {
System.out.println("main-thread 获取到了锁");
sleep(3);
/*其他线程执行过程中，slave线程自己打断自己获取锁的等待*/
slaveThread.interrupt();
} finally {
lock.unlock();
}
}
public static void sleep(int seconds) {
try {
TimeUnit.SECONDS.sleep(seconds);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
3. 超时锁
- 等待一段时间后，如果没有获取到锁，则中断获取锁的竞争
package com.dreamer.multithread.day01;
import java.util.concurrent.locks.ReentrantLock;
public class Demo03 {
private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
Thread slaveThread = new Thread() {
@Override
public void run() {
/*尝试获取锁，如果没获取到，则直接返回*/
boolean isLocked = lock.tryLock();
if (!isLocked) {
System.out.println("slave-thread没有获取到锁");
return;
}
try {
System.out.println("slave-thread获取到了锁，执行业务流程");
} finally {
lock.unlock();
}
}
};
lock.lock();
slaveThread.start();
}
}
- 在等待的过程中，依然可以被打断
- 在等待的过程中，如果获取到了锁，则执行正常的业务流程
package com.dreamer.multithread.day01;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.locks.ReentrantLock;
public class Demo03 {
private static ReentrantLock lock = new ReentrantLock();
public static void main(String[] args) {
Thread slaveThread = new Thread() {
@Override
public void run() {
/*1. 尝试在2s内获取锁，如果没获取到，则直接返回
* 2. 等待的过程可以被打断*/
boolean isLocked = false;
try {
isLocked = lock.tryLock(5, TimeUnit.SECONDS);
if (!isLocked) {
System.out.println("slave-thread等待没有获取到锁");
return;
}
} catch (InterruptedException e) {
e.printStackTrace();
System.out.println("slave-thread被打断，没有获取到锁");
return;
}
try {
System.out.println("slave-thread获取到了锁，执行业务流程");
} finally {
lock.unlock();
}
}
};
lock.lock();
slaveThread.start();
sleep(2);
slaveThread.interrupt();
lock.unlock();
}
public static void sleep(int seconds) {
try {
TimeUnit.SECONDS.sleep(seconds);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
标签：lock,ReentrantLock,获取,线程,println,public 来源： https://blog.csdn.net/weixin_43374578/article/details/120650939
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。