一、CountDownLatch允许一个或者多个线程等待其他线程完成操作。

0、设置子线程数

RCountDownLatch countDownLatch = redissonClient.getCountDownLatch(DATASOURCE_PLAN_ID + plan.getPlanId());countDownLatch.trySetCount(10);

1、等待线程

 // 等待子线程完成，等待时间30scountDownLatch.await(30, TimeUnit.SECONDS);

2、子线程完成后，减一

RCountDownLatch countDownLatch = redissonClient.getCountDownLatch(redisPrefixKey + this.getPlanId());
countDownLatch.countDown();

二、Semaphore是一个计数信号量，常用于限制可以访问某些资源（物理或逻辑的）线程数目。

RPermitExpirableSemaphore semaphore = redisson.getPermitExpirableSemaphore("mySemaphore");
String permitId = semaphore.acquire();
// 获取一个信号，有效期只有2秒钟。
String permitId = semaphore.acquire(2, TimeUnit.SECONDS);
// ...
semaphore.release(permitId);