云中侠 2017-08-14 12:52 采纳率: 0%
浏览 1022

Zookeeper的Curator客户端异步创建节点,没有先后顺序吗?

先上代码:

 package book.chapter05.$5_4_2;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.api.BackgroundCallback;
import org.apache.curator.framework.api.CuratorEvent;
import org.apache.curator.retry.ExponentialBackoffRetry;
import org.apache.zookeeper.CreateMode;

//使用Curator的异步接口
public class Create_Node_Background_Sample {

    static String path = "/zk-book";

    static CuratorFramework client = CuratorFrameworkFactory.builder()
            .connectString("domain1.book.zookeeper:2181")
            .sessionTimeoutMs(5000)
            .retryPolicy(new ExponentialBackoffRetry(1000, 3))
            .build();
    static CountDownLatch semaphore = new CountDownLatch(2);
    static ExecutorService tp = Executors.newFixedThreadPool(2);

    public static void main(String[] args) throws Exception {
        client.start();
        System.out.println("Main thread: " + Thread.currentThread().getName());
        // 此处传入了自定义的Executor
        client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).inBackground(new BackgroundCallback() {
            @Override
            public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
                System.out.println("One event[code: " + event.getResultCode() + ", type: " + event.getType() + "]");
                System.out.println("One Thread of processResult: " + Thread.currentThread().getName());
                semaphore.countDown();
            }
        }, tp).forPath(path, "init".getBytes());
        // 此处没有传入自定义的Executor
        client.create().creatingParentsIfNeeded().withMode(CreateMode.PERSISTENT).inBackground(new BackgroundCallback() {
            @Override
            public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {
                System.out.println("Two event[code: " + event.getResultCode() + ", type: " + event.getType() + "]");
                System.out.println("Two Thread of processResult: " + Thread.currentThread().getName());
                semaphore.countDown();
            }
        }).forPath(path, "init2".getBytes());

        semaphore.await();
        System.out.println("通过CountDownLatch主线程一直等待,直到计数减到0");
        tp.shutdown();
    }
}

运行结果情况(1):

Main thread: main
Two event[code: 0, type: CREATE]
Two Thread of processResult: main-EventThread
One event[code: -110, type: CREATE]
One Thread of processResult: pool-3-thread-1
通过CountDownLatch主线程一直等待,直到计数减到0

运行结果情况(2):

Main thread: main
Two event[code: -110, type: CREATE]
Two Thread of processResult: main-EventThread
One event[code: 0, type: CREATE]
One Thread of processResult: pool-3-thread-1
通过CountDownLatch主线程一直等待,直到计数减到0

问题内容:

请问一下,主线程中是 One先创建的节点,然后才是Two创建的节点,zookeeper对于同一客户端的会话请求不是顺序执行的吗?为什么有时候是Two先创建的节点,有时候是One先创建成功节点呢?

  • 写回答

1条回答 默认 最新

  • threenewbee 2017-08-14 16:30
    关注

    异步是不能保证顺序的,如果你要保证顺序,就得做同步

    评论

报告相同问题?

悬赏问题

  • ¥15 ubuntu虚拟机打包apk错误
  • ¥199 rust编程架构设计的方案 有偿
  • ¥15 回答4f系统的像差计算
  • ¥15 java如何提取出pdf里的文字?
  • ¥100 求三轴之间相互配合画圆以及直线的算法
  • ¥100 c语言,请帮蒟蒻写一个题的范例作参考
  • ¥15 名为“Product”的列已属于此 DataTable
  • ¥15 安卓adb backup备份应用数据失败
  • ¥15 eclipse运行项目时遇到的问题
  • ¥15 关于#c##的问题:最近需要用CAT工具Trados进行一些开发