首页 > 其他 > 详细

zookeeper选举-Messenger

时间:2020-09-30 17:15:54      阅读:41      评论:0      收藏:0      [点我收藏+]
FastLeaderElection.Messenger 
投票信息传输

protected class Messenger {

        WorkerSender ws;

        WorkerReceiver wr;

        Messenger(QuorumCnxManager manager) {
            this.ws = new WorkerSender(manager);
            Thread t = new Thread(this.ws, "WorkerSender[myid=" + self.getId() + "]");
            t.setDaemon(true);
            t.start();

            this.wr = new WorkerReceiver(manager);
            t = new Thread(this.wr, "WorkerReceiver[myid=" + self.getId() + "]");
            t.setDaemon(true);
            t.start();
        }

        void halt() {
            this.ws.stop = true;
            this.wr.stop = true;
        }
    }

  

zookeeper选举-Messenger

原文:https://www.cnblogs.com/zhwcs/p/13754874.html

(0)
(0)
   
举报
评论 一句话评论(0
关于我们 - 联系我们 - 留言反馈 - 联系我们:wmxa8@hotmail.com
© 2014 bubuko.com 版权所有
打开技术之扣,分享程序人生!