Redisson读写锁
redisson
Redisson - Easy Redis Java client with features of In-Memory Data Grid. Sync/Async/RxJava/Reactive API. Over 50 Redis based Java objects and services: Set, Multimap, SortedSet, Map, List, Queue, Deque, Semaphore, Lock, AtomicLong, Map Reduce, Bloom filter, Spring Cache, Tomcat, Scheduler, JCache API, Hibernate, RPC, local cache ...
项目地址:https://gitcode.com/gh_mirrors/re/redisson
免费下载资源
·
读写锁
一次只有一个线程可以占有写模式的读写锁, 但是可以有多个线程同时占有读模式的读写锁. 正是因为这个特性,
当读写锁是写加锁状态时, 在这个锁被解锁之前, 所有试图对这个锁加锁的线程都会被阻塞.
当读写锁在读加锁状态时, 所有试图以读模式对它进行加锁的线程都可以得到访问权, 但是如果线程希望以写模式对此锁进行加锁, 它必须直到所有的线程释放锁.
通常, 当读写锁处于读模式锁住状态时, 如果有另外线程试图以写模式加锁, 读写锁通常会阻塞随后的读模式锁请求, 这样可以避免读模式锁长期占用, 而等待的写模式锁请求长期阻塞.
读写锁适合于对数据结构的读次数比写次数多得多的情况. 因为, 读模式锁定时可以共享, 以写模式锁住时意味着独占, 所以读写锁又叫共享-独占锁.
使用redisson验证读写锁
- 给容器中返回一个RedissonClient 的bean
@Bean
public RedissonClient redissonClient(){
Config config = new Config();
config.useSingleServer().setAddress("redis://127.0.0.1:6379");
return Redisson.create(config);
}
-
在redis服务器中保存一个值
-
编写验证读锁的请求
@GetMapping("read")
public String read(){
RReadWriteLock readWriteLock = redissonClient.getReadWriteLock(RedisConstant.READ_WRITE_LOCK);
//读之前加读锁,读锁的作用就是等待该lockkey释放写锁以后再读
RLock rLock = readWriteLock.readLock();
try {
rLock.lock();
String uuid = redisTemplate.opsForValue().get("uuid");
return uuid;
}finally {
rLock.unlock();
}
}
- 编写验证写锁的请求
@GetMapping("write")
public String write() throws InterruptedException {
RReadWriteLock readWriteLock = redissonClient.getReadWriteLock(RedisConstant.READ_WRITE_LOCK);
//写之前加写锁,写锁加锁成功,读锁只能等待
RLock rLock = readWriteLock.writeLock();
String s = "";
try {
rLock.lock();
s = UUID.randomUUID().toString();
Thread.sleep(10000);
redisTemplate.opsForValue().set("uuid",s);
}finally {
rLock.unlock();
}
return s;
}
-
打开浏览器先访问read请求
我们发现此时是可以正常访问到的。 -
现在我们先访问写请求,注意:写请求加了Thread.sleep(10000);模拟耗时,当我们访问完写请求,再接着访问读请求看是什么效果。
可以发现,读写在写锁加锁后是无法进行读取的,只有当写锁释放以后,读锁才可以执行,这样就保证了读取到的数据是最新的数据。
- 现在我们先访问读请求,注意:读请求加了Thread.sleep(10000);模拟耗时,而写请求中的Thread.sleep(10000);我们去掉,当我们访问完读请求,再接着访问写请求看是什么效果。
可以 发现,当如果先访问了读请求,再访问写请求,那么此时写请求是无法执行的,必须等待读请求完成以后再执行。
当全部执行完以后,读请求读到的就不是最新的结果了,是上一次写请求执行完的结果。
无论是读请求先执行还是写请求先执行,只要涉及到写锁,则都会阻塞,如果是先写再读,则读锁等待,如果是先读再写,则写锁等待
GitHub 加速计划 / re / redisson
23.06 K
5.31 K
下载
Redisson - Easy Redis Java client with features of In-Memory Data Grid. Sync/Async/RxJava/Reactive API. Over 50 Redis based Java objects and services: Set, Multimap, SortedSet, Map, List, Queue, Deque, Semaphore, Lock, AtomicLong, Map Reduce, Bloom filter, Spring Cache, Tomcat, Scheduler, JCache API, Hibernate, RPC, local cache ...
最近提交(Master分支:2 个月前 )
15bd94ed - 2 个月前
d220f2a8 - 3 个月前
更多推荐
已为社区贡献8条内容
所有评论(0)