-
线程安全是一个多线程环境下正确性的概念,也就是保证多线程环境下共享的、可修改的状态的正确性,这里的状态反映在程序中其实可以看作是数据. 换个角度来看,如果状态不是共享的,或者不是可修改的,也就不存在线程安全问题
-
线程安全需要保证几个基本特性:
原子性,简单说就是相关操作不会中途被其他线程干扰,一般通过同步机制实现。
可见性,是一个线程修改了某个共享变量,其状态能够立即被其他线程知晓,通常被解释为将线程本地状态反映到主内存上,volatile 就是负责保证可见性的。
有序性,是保证线程内串行语义,避免指令重排等。
-
完全可以替代synchronied关键字.(早期前者性能好,但jdk6以后差距不大) .
此外的高级功能:- 中断响应:可在等待锁的过程中,根据需求取消对锁的请求,无需再等待,可停止工作了.对于处理死锁有一定帮助. 可中断的请求锁:lock.lockInterruptibly() 释放锁:lock.isHeldByCurrentThread();lock.unlock().
与synchronized不同,获取到锁的线程能够响应中断,当获取到锁的线程被中断时,中断异常将会被抛出,同时锁会被释放
- 中断响应:可在等待锁的过程中,根据需求取消对锁的请求,无需再等待,可停止工作了.对于处理死锁有一定帮助. 可中断的请求锁:lock.lockInterruptibly() 释放锁:lock.isHeldByCurrentThread();lock.unlock().
- 锁申请等待限时/尝试 (tryLock()也可以不带参数 不行直接就false)
- 公平锁
- 条件变量 如果说 ReentrantLock 是 synchronized 的替代选择,Condition 则是将 wait、notify、notifyAll 等操作转化为相应的对象的操作(wait/signal),将复杂而晦涩的同步操作转变为直观可控的对象行为。 典型应用场景 ArrayBlockingQueue
/** Condition for waiting takes */
private final Condition notEmpty;
/** Condition for waiting puts */
private final Condition notFull;
public ArrayBlockingQueue(int capacity, boolean fair) {
if (capacity <= 0)
throw new IllegalArgumentException();
this.items = new Object[capacity];
lock = new ReentrantLock(fair);
//两个条件变量是从同一再入锁创建出来,然后使用在特定操作中
notEmpty = lock.newCondition();
notFull = lock.newCondition();
}
public E take() throws InterruptedException {
final ReentrantLock lock = this.lock;
lock.lockInterruptibly();
try {
while (count == 0)
notEmpty.await();
return dequeue();
} finally {
lock.unlock();
}
}
//当队列为空时,试图 take 的线程的正确行为应该是等待入队发生,而不是直接返回,这是 BlockingQueue 的语义,使用条件 notEmpty 就可以优雅地实现这一逻辑。
//那么,怎么保证入队触发后续 take 操作呢?请看 enqueue 实现:
private void enqueue(E e) {
// assert lock.isHeldByCurrentThread();
// assert lock.getHoldCount() == 1;
// assert items[putIndex] == null;
final Object[] items = this.items;
items[putIndex] = e;
if (++putIndex == items.length) putIndex = 0;
count++;
notEmpty.signal(); // 通知等待的线程,非空条件已经满足
}
网友评论