Commit f95291c

committed

add count down latch await in redisson sample

1 parent fe1263e commit f95291cCopy full SHA for f95291c

File tree

1 file changed

-5

lines changed

springboot-redisson-sample/src/main/java/com/ipman/springboot/redisson/sample/examples
- RedissonExamples.java

1 file changed

-5

lines changed

`‎springboot-redisson-sample/src/main/java/com/ipman/springboot/redisson/sample/examples/RedissonExamples.java‎`

Lines changed: 8 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -109,10 +109,13 @@ public void map() {`
`109`	`109`	`System.out.println("Map async put:" + futurePut.get());`
`110`	`110`	`System.out.println("Map async get:" + futureGet.get());`
`111`	`111`
	`112`	`+ // 阻塞等待`
	`113`	`+ int count = 6;`
	`114`	`+ CountDownLatch latch = new CountDownLatch(count);`
`112`	`115`
`113`	`116`	`// Map 对象锁,先获取锁,才能操作 Map 集合`
`114`	`117`	`String k = "mapLock";`
`115`		`- for (int i = 0; i < 3; i++) {`
	`118`	`+ for (int i = 0; i < count / 2; i++) {`
`116`	`119`	`Thread t = new Thread(() -> {`
`117`	`120`	`RLock keyLock = map.getLock(k);`
`118`	`121`	`keyLock.lock();`
`@@ -122,14 +125,15 @@ public void map() {`
`122`	`125`	`// 其他业务逻辑`
`123`	`126`	`} finally {`
`124`	`127`	`keyLock.unlock();`
	`128`	`+ latch.countDown();`
`125`	`129`	`}`
`126`	`130`	`});`
`127`	`131`	`t.setName("thread-" + i);`
`128`	`132`	`t.start();`
`129`	`133`	`}`
`130`	`134`
`131`	`135`	`// Map 读写锁,读时不能写`
`132`		`- for (int i = 0; i < 3; i++) {`
	`136`	`+ for (int i = 0; i < count / 2; i++) {`
`133`	`137`	`Thread t = new Thread(() -> {`
`134`	`138`	`RReadWriteLock rwLock = map.getReadWriteLock(k);`
`135`	`139`	`rwLock.readLock().lock();`
`@@ -139,15 +143,14 @@ public void map() {`
`139`	`143`	`// 其他业务逻辑`
`140`	`144`	`} finally {`
`141`	`145`	`rwLock.readLock().unlock();`
	`146`	`+ latch.countDown();`
`142`	`147`	`}`
`143`	`148`	`});`
`144`	`149`	`t.setName("thread-" + i);`
`145`	`150`	`t.start();`
`146`	`151`	`}`
`147`	`152`
`148`		`- // 阻塞等待`
`149`		`- System.in.read();`
`150`		`-`
	`153`	`+ latch.await();`
`151`	`154`	`}`
`152`	`155`
`153`	`156`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Commit f95291c

File tree

1 file changed

1 file changed

`‎springboot-redisson-sample/src/main/java/com/ipman/springboot/redisson/sample/examples/RedissonExamples.java‎`

0 commit comments