@Test
void testConcurrent() throws Exception {

    ExecutorService executor = Executors.newFixedThreadPool(100);
    for (int i = 0; i < LOOP; i++) {
        executor.execute(() -> {
            ZkUtils.changeZkValue(curatorFramework, TEST_PATH2, old -> old + 1, this::intDecode,
                    this::intEncode);
        });
    }
    MoreExecutors.shutdownAndAwaitTermination(executor, 1, DAYS);
    assertEquals(intDecode(curatorFramework.getData().forPath(TEST_PATH2)), LOOP);
}