教程簡介 亞馬遜商城快速指南 - 從簡單和簡單的步驟開始學習亞馬遜商城,從基本到高級概念,包括為什麼選擇亞馬遜?,亞馬遜優勢,帳戶類型,銷售什麼?,產品列表,費用,帳戶設置,購買盒,運輸方式,列出新產品,定價工具,獲取最高利潤,價格計算器,稅務處理,運輸流程,亞馬遜賣家中心,管理庫存,創建報告,管理 ...
一、什麼是讀寫鎖
讀寫鎖是JDK1.5提供的一個工具鎖,適用於讀多寫少的場景,將讀寫分離,從而提高併發性。
二、讀寫鎖的特點
讀鎖是共用鎖,寫鎖是排他鎖,讀鎖和寫鎖不能同時存在;
讀鎖不能升級為寫鎖;
寫鎖可以降級為讀鎖;
三、鎖的本質
鎖的本質就是鎖住一塊資源而不是一塊代碼. 在常見的一些代碼實現都是加一把大鎖,將這一塊代碼資源統一加鎖,無法針對資源進行精確進行鎖控制.
四、代碼實現
`
import lombok.extern.slf4j.Slf4j;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
@Slf4j
public class UserDefinedLock {
final ConcurrentHashMap<String, ReadWriteLock> map = new ConcurrentHashMap<>();
public UserDefinedLock() {
}
/**
* 從map里獲取鎖 如果存在則返回 不存在則創建
*
* @param key key
* @return lock
*/
public void createOrGetLock(String key) {
synchronized (key.intern()) {
map.compute(key, (k, lock) -> {
if (lock == null) {
lock = new ReentrantReadWriteLock();
}
return lock;
});
}
}
/**
* 獲取鎖 會阻塞
*
* @param key key
*/
public void writeLock(String key) {
map.get(key).writeLock().lock();
}
public void readLock(String key) {
map.get(key).readLock().lock();
}
/**
* 釋放鎖 必須由申請鎖的線程進行調用
*
* @param key key
*/
public void unWriteLock(String key) {
ReadWriteLock lock = map.get(key);
if (null != lock) {
try {
lock.writeLock().unlock();
} catch (Exception e) {
log.error("釋放寫鎖失敗,key:{}, msg:{}", key, e.getMessage());
}
}
}
public void unReadLock(String key) {
ReadWriteLock lock = map.get(key);
if (null != lock) {
try {
lock.readLock().unlock();
} catch (Exception e) {
log.error("釋放讀鎖失敗,key:{}, msg:{}", key, e.getMessage());
}
}
}
public static void main(String[] args) {
UserDefinedLock userDefinedLock = new UserDefinedLock();
ArrayList list = new ArrayList<String>();
for (int i = 0; i < 5; i++) {
String key = String.valueOf("測試" + i);
new Thread(() -> {
try {
userDefinedLock.createOrGetLock(key);
userDefinedLock.readLock(key);
System.out.println("-----" + key + "----");
list.add(key);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
userDefinedLock.unReadLock(key);
}
}, "read-" + key).start();
}
}
}
`