private void batchWriteTest(RheaKVStore store) throws ExecutionException, InterruptedException {
        // regions: 1 -> [null, g), 2 -> [g, t), 3 -> [t, null)
        List<CompletableFuture<Boolean>> futures = Lists.newArrayList();
        for (int i = 0; i < 100; i++) {
            CompletableFuture<Boolean> f = store.put(makeKey("batch" + i), makeValue("batch"));
            futures.add(f);
        }
        FutureGroup<Boolean> futureGroup = new FutureGroup<>(futures);
        CompletableFuture.allOf(futureGroup.toArray()).get();

        futures.clear();
        for (int i = 0; i < 100; i++) {
            CompletableFuture<Boolean> f = store.delete(makeKey("batch" + i));
            futures.add(f);
        }
        futureGroup = new FutureGroup<>(futures);
        CompletableFuture.allOf(futureGroup.toArray()).get();

        for (int i = 0; i < 100; i++) {
            byte[] value = store.bGet(makeKey("batch" + i));
            assertNull(value);
        }
    }
Test method: {@link RheaKVStore#getDistributedLock(byte[], long, TimeUnit)}
jraft-rheakv/rheakv-core/src/test/java/com/alipay/sofa/jraft/rhea/storage/rhea/AbstractRheaKVStoreTest.java