我们在处理并发操作的时候经常使用锁机制,大家常用的synchronized和Lock.
1.二者使用方式有所不同:
synchronized可以在方法前或者代码块中,synchronized是java中的内置锁,由jvm控制锁的释放。
Lock使用在代码块中,加锁之后需要显示的释放,一般在finally中释放锁,主要有两种锁ReentrantLock和ReentrantReadWriteLock。
2.二者都是互斥锁,也就是一次只能有一个对象持有该锁。
3.synchronized原始采用的是CPU悲观锁机制,即线程获得的是独占锁。独占锁意味着其 他线程只能依靠阻塞来等待线程释放锁。而在CPU转换线程阻塞时会引起线程上下文切换,当有很多线程竞争锁的时候,会引起CPU频繁的上下文切换导致效率很低。
Lock采用的是乐观锁方式,所谓乐观锁就是,每次不加锁而是假设没有冲突而去完成某项操作,如果因为冲突失败就重试,直到成功为止。是非阻塞的。
一般情况下我们使用synchronized就可以满足并发控制,对应高性能的锁机制,我们可以使用ReentrantLock-可重入锁。
java.util.concurrent提供了支持并发数据结构的操作,通过这些我们也可以了解ReentrantLock使用的情形。
ConcurrentHashMap:采用ReentrantLock进行并发控制。
LinkedBlockingDeque:双向阻塞队列,可以作为栈使用,采用ReentrantLock进行并发控制。
LinkedBlockingQueue:阻塞队列,采用ReentrantLock进行并发控制。
如:
/** Lock held by take, poll, etc */
private final ReentrantLock takeLock = new ReentrantLock();
/** Wait queue for waiting takes */
private final Condition notEmpty = takeLock.newCondition();
对于阻塞队列,主要是使用take()方法:返回并且移除队列头部元素,当队列中没有可用元素时,处于阻塞等待状态。
源代码如:
public E take() throws InterruptedException {
E x;
int c = -1;
final AtomicInteger count = this.count;
final ReentrantLock takeLock = this.takeLock;
takeLock.lockInterruptibly();
try {
while (count.get() == 0) {
notEmpty.await();
}
x = dequeue();
c = count.getAndDecrement();
if (c > 1)
notEmpty.signal();
} finally {
takeLock.unlock();
}
if (c == capacity)
signalNotFull();
return x;
}
可用看到,该方法通过可重入锁ReentrantLock进行并发控制的。其中Condition的
notEmpty.signal()表示唤醒等待中的线程,notEmpty.await()使当前的线程处于等待状态,直到被唤醒或者被中断。
分享到:
相关推荐
Java 5.0版本中引入了java.util.concurrent.locks包,其中提供了LockSupport类,它是创建锁和其他同步类的基本线程阻塞原语。LockSupport类中的park方法用于阻塞当前线程,直到获取许可证;unpark方法用于释放指定...
java.util.concurrent.*包是Java并发编程中不可或缺的一部分,它提供了大量用于多线程编程的接口和类。这个包中的类主要包括同步器、并发集合、执行器框架、原子变量、锁等不同类型的并发工具。通过这些工具,Java...
ReentrantLock,即可重入锁,是Java并发包(java.util.concurrent.locks)中的一个核心组件,它提供了比synchronized更灵活的锁机制。ReentrantLock实现了Lock接口,具备公平锁与非公平锁两种模式,同时支持中断等待...
线程间通信可以使用wait(), notify()和notifyAll()方法,以及锁(synchronized)、条件变量(java.util.concurrent.Condition)等机制。并发控制还包括volatile关键字、ThreadLocal、CountDownLatch、CyclicBarrier...
ReentrantLock是Java.util.concurrent.locks包中提供的一个可重入的互斥锁,它比内置锁synchronized提供了更灵活的锁定操作,比如可以尝试锁定、非阻塞的获取锁等。 在内存语义方面,当线程获取锁时,Java内存模型...
为了防止这种情况,JDK开发团队引入了并发包(java.util.concurrent)中的ThreadLocalRandom类,它是针对并发场景优化的随机数生成器。 ThreadLocalRandom类通过使用ThreadLocal变量来存储每个线程的私有Random实例...
Java JavaScript PHP iOS Android HTML5 CSS3 Linux C++ Python C# Node.Js 一文让你彻底理解 Java HashMap 和 ConcurrentHashMap 2018-07-25 分类:JAVA开发、编程开发、首页精华0人评论 ...