1主穗、Lock接口
鎖是用來控制多個線程訪問共享資源的方式芋齿，一般來說鎖能夠防止多個線程同時訪問共享資源（有的鎖可以允許多個線程訪問共享資源，比如說讀寫鎖）奇颠，在Lock接口出現(xiàn)之前民珍，java程序是靠synchronized關(guān)鍵字實現(xiàn)鎖功能的襟士，但是在JKD1.5之后并發(fā)包中新增了Lock接口及其實現(xiàn)來實現(xiàn)鎖的功能盗飒。它提供了synchronized關(guān)鍵字類似的功能，但是Lock需要顯示的獲取鎖陋桂、釋放鎖逆趣，而synchronized是通過隱式的方式來實現(xiàn)獲取、釋放鎖嗜历。
Lock接口常見的API請自行查找
2宣渗、隊列同步器
略...
3、重入鎖
重入鎖ReentrantLock秸脱，顧名思義落包，就是支持重進入的鎖，重入鎖支持同一個線程多次的獲取鎖摊唇。除此之外，該鎖還支持獲取鎖時的公平和非公平性涯鲁。
關(guān)于鎖的公平性巷查，如果在絕對的時間上，先對鎖進行獲取請求的操作一定會先被滿足抹腿，則說明這個鎖是公平的岛请，反之則是不公平的。ReentrantLock的構(gòu)造函數(shù)支持構(gòu)造公平鎖與非公平鎖警绩，默認(rèn)為非公平鎖崇败，因為非公平鎖能減少上下文切換，開銷更小肩祥。
4后室、讀寫鎖
讀寫鎖支持同一時刻允許多個線程同時訪問，但是在寫線程訪問時混狠，所有的讀線程與其他的寫線程均被阻塞岸霹。讀寫鎖維護了一對鎖，讀鎖與寫鎖将饺，通過讀鎖與寫鎖的分離贡避，讀寫鎖的并發(fā)性相比于其他排他鎖都有很大的提升。
java并發(fā)包提供的讀寫鎖是ReentrantReadWriteLock予弧，它具有公平性選擇刮吧、鎖重入、鎖降級三個特性掖蛤。
讀寫鎖實現(xiàn)簡單緩存demo
package main.java.com.robot.demo;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
/**
* @author: 會跳舞的機器人
* @date: 2017/8/16 14:45
* @description: 讀寫鎖實現(xiàn)緩存demo
*/
public class Cache {
static Map<String, Object> map = new HashMap<>();
static ReentrantReadWriteLock rwl = new ReentrantReadWriteLock();
static Lock writeLock = rwl.writeLock();
static Lock readLock = rwl.readLock();
/**
* 讀緩存
*/
public static final Object get(String key) {
readLock.lock();
try {
return map.get(key);
} finally {
readLock.unlock();
}
}
/**
* 寫入緩存
*/
public static final Object put(String key, Object value) {
writeLock.lock();
try {
return map.put(key, value);
} finally {
writeLock.unlock();
}
}
/**
* 清空緩存
*/
public static final void clear() {
writeLock.lock();
try {
map.clear();
} finally {
writeLock.unlock();
}
}
/**
* 獲取緩存大小
*/
public static final int size() {
writeLock.lock();
try {
return map.size();
} finally {
writeLock.unlock();
}
}
}
5杀捻、LockSupport工具
略...
6、Condition接口
利用Condition接口來實現(xiàn)一個簡單的有界阻塞隊列坠七，當(dāng)隊列為空時水醋，隊列的獲取操作將會阻塞獲取線程旗笔，知道有新的元素添加進來，當(dāng)隊列滿時拄踪，隊列的插入操作將會阻塞插入線程蝇恶，知道隊列出現(xiàn)“空位”。
package main.java.com.robot.demo;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
/**
* @author: 會跳舞的機器人
* @date: 2017/8/16 15:48
* @description: Condition實現(xiàn)有界阻塞隊列demo
*/
public class BoundedQueue {
private Object[] items;
private int addIndex, removeIndex, count;
private Lock lock = new ReentrantLock();
private Condition notEmpty = lock.newCondition();
private Condition notFull = lock.newCondition();
public BoundedQueue(int size) {
items = new Object[size];
}
/**
* 添加一個元素惶桐，如果隊列已滿撮弧，則線程進入等待狀態(tài)，直到有空位為止
*/
public void add(Object object) throws InterruptedException {
lock.lock();
try {
// 隊列已滿姚糊，阻塞線程
while (items.length == count) {
System.out.println("隊列已滿贿衍，等待......");
notFull.await();
}
items[addIndex] = object;
if (++addIndex == items.length) {
addIndex = 0;
}
++count;
// 喚醒
notEmpty.signal();
} finally {
lock.unlock();
}
}
/**
* 刪除隊列的第一個元素，如果隊列為空救恨，則線程進入等待狀態(tài)贸辈，直到有新元素添加進來
*/
public Object remove() throws InterruptedException {
lock.lock();
try {
while (count == 0) {
System.out.println("空隊列，等待......");
notEmpty.await();
}
Object obj = items[removeIndex];
if (++removeIndex == items.length) {
removeIndex = 0;
}
--count;
notFull.signal();
return obj;
} finally {
lock.unlock();
}
}
}
