在Messenger里面構(gòu)建了兩個(gè)線程，一個(gè)是WorkerSender，一個(gè)是WorkerReceiver。?這兩個(gè)線程是分別用來發(fā)送和接收消息的線程。具體做什么，暫時(shí)先不分析。

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(); }

?

總結(jié)

以上是生活随笔為你收集整理的leader选举的源码分析-Messenger的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。