Java多線程編程概述
- Java多線程編程
- Java多線程的創(chuàng)建與啟動(dòng)方式
- Java多線程常用的方法
- Java多線程的生命周期
- Java多線程編程的優(yōu)勢(shì)與風(fēng)險(xiǎn)
Java多線程的安全問題
Java多線程同步
- Java多線程同步機(jī)制簡(jiǎn)介
- Java多線程鎖
- Java多線程同步代碼塊Synchronized
- Java多線程同步方法
- Java多線程臟讀
- Java多線程出現(xiàn)異常會(huì)自動(dòng)釋放鎖
- Java多線程死鎖
- Java volatile關(guān)鍵字的作用
- Java多線程之volatile非原子性
- Java原子類自增自減操作
- Java CAS多線程
- Java原子變量
Java多線程間的通信
- Java線程間的通信方式
- Java多線程的等待通知機(jī)制
- Java生產(chǎn)者消費(fèi)者模式
- Java中利用管道實(shí)現(xiàn)線程間的通訊
- Java線程中join方法
- Java ThreadLocal使用
Java線程Lock
- Java中鎖的可重入性
- Java ReentrantLock使用
- ReentrantLock可重入性
- Java多線程：lockInterruptibly()方法
- Java多線程：tryLock()方法
- Java多線程：newCondition()方法
- Java公平鎖與非公平鎖
- Lock鎖的常用方法
- Java多線程讀寫鎖
Java多線程管理
- Java線程組
- Java多線程捕獲異常處理
- Hook鉤子線程注入
- Java線程池是什么
- 多線程JDK線程池
- Java線程池的底層實(shí)現(xiàn)
- Java線程池的拒絕策略
- Java線程池ThreadFactory
- Java監(jiān)控線程池
- Java線程池?cái)U(kuò)展
- Java線程池的大小與線程池死鎖
- Java線程池異常處理
- Java ForkJoinPool線程池
保障線程安全的設(shè)計(jì)技術(shù)
Java鎖的優(yōu)化及注意事項(xiàng)
Java多線程集合
【Java多線程】單例模式與多線程
Java多線程：lockInterruptibly()方法
lockInterruptibly() 方法的作用：如果當(dāng)前線程未被中斷則獲得鎖,如果當(dāng)前線程被中斷則出現(xiàn)異常。
package com.wkcto.lock.reentrant;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* lockInterruptibly() 方法的作用:如果當(dāng)前線程未被中斷則獲得鎖,如果當(dāng)前線程被中斷則出現(xiàn)異常.
*/
public class Test05 {
static class Servier{
private Lock lock = new ReentrantLock(); //定義鎖對(duì)象
public void serviceMethod(){
try {
// lock.lock(); //獲得鎖定,即使調(diào)用了線程的interrupt()方法,也沒有真正的中斷線程
lock.lockInterruptibly(); //如果線程被中斷了,不會(huì)獲得鎖,會(huì)產(chǎn)生異常
System.out.println(Thread.currentThread().getName() + "-- begin lock");
//執(zhí)行一段耗時(shí)的操作
for (int i = 0; i < Integer.MAX_VALUE; i++) {
new StringBuilder();
}
System.out.println( Thread.currentThread().getName() + " -- end lock");
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
System.out.println( Thread.currentThread().getName() + " ***** 釋放鎖");
lock.unlock(); //釋放鎖
}
}
}
public static void main(String[] args) throws InterruptedException {
Servier s = new Servier();
Runnable r = new Runnable() {
@Override
public void run() {
s.serviceMethod();
}
};
Thread t1 = new Thread(r);
t1.start();
Thread.sleep(50);
Thread t2 = new Thread(r);
t2.start();
Thread.sleep(50);
t2.interrupt(); //中斷t2線程
}
}
對(duì)于synchronized內(nèi)部鎖來說，如果一個(gè)線程在等待鎖,只有兩個(gè)結(jié)果：要么該線程獲得鎖繼續(xù)執(zhí)行;要么就保持等待。
對(duì)于ReentrantLock可重入鎖來說，提供另外一種可能,在等待鎖的過程中，程序可以根據(jù)需要取消對(duì)鎖的請(qǐng)求。
package com.wkcto.lock.reentrant;
import com.wkcto.pipestream.Test2;
import java.util.Random;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* 通過ReentrantLock鎖的lockInterruptibly()方法避免死鎖的產(chǎn)生
*/
public class Test06 {
static class IntLock implements Runnable{
//創(chuàng)建兩個(gè)ReentrantLock 鎖對(duì)象
public static ReentrantLock lock1 = new ReentrantLock();
public static ReentrantLock lock2 = new ReentrantLock();
int lockNum; //定義整數(shù)變量,決定使用哪個(gè)鎖
public IntLock(int lockNum) {
this.lockNum = lockNum;
}
@Override
public void run() {
try {
if ( lockNum % 2 == 1){ //奇數(shù),先鎖1,再鎖2
lock1.lockInterruptibly();
System.out.println(Thread.currentThread().getName() + "獲得鎖1,還需要獲得鎖2");
Thread.sleep(new Random().nextInt(500));
lock2.lockInterruptibly();
System.out.println(Thread.currentThread().getName() + "同時(shí)獲得了鎖1與鎖2....");
}else { //偶數(shù),先鎖2,再鎖1
lock2.lockInterruptibly();
System.out.println(Thread.currentThread().getName() + "獲得鎖2,還需要獲得鎖1");
Thread.sleep(new Random().nextInt(500));
lock1.lockInterruptibly();
System.out.println(Thread.currentThread().getName() + "同時(shí)獲得了鎖1與鎖2....");
}
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
if ( lock1.isHeldByCurrentThread()) //判斷當(dāng)前線程是否持有該鎖
lock1.unlock();
if (lock2.isHeldByCurrentThread())
lock2.unlock();
System.out.println( Thread.currentThread().getName() + "線程退出");
}
}
}
public static void main(String[] args) throws InterruptedException {
IntLock intLock1 = new IntLock(11);
IntLock intLock2 = new IntLock(22);
Thread t1 = new Thread(intLock1);
Thread t2 = new Thread(intLock2);
t1.start();
t2.start();
//在main線程,等待3000秒,如果還有線程沒有結(jié)束就中斷該線程
Thread.sleep(3000);
//可以中斷任何一個(gè)線程來解決死鎖, t2線程會(huì)放棄對(duì)鎖1的申請(qǐng),同時(shí)釋放鎖2, t1線程會(huì)完成它的任務(wù)
if (t2.isAlive()){ t2.interrupt();}
}
}
