這篇文章主要介紹“Curator的分布式Barrier怎么實現”的相關知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“Curator的分布式Barrier怎么實現”文章能幫助大家解決問題。

創(chuàng)新互聯是一家成都做網站、成都網站建設，提供網頁設計，網站設計，網站制作，建網站，按需網站開發(fā)，網站開發(fā)公司，自2013年創(chuàng)立以來是互聯行業(yè)建設者，服務者。以提升客戶品牌價值為核心業(yè)務，全程參與項目的網站策劃設計制作，前端開發(fā)，后臺程序制作以及后期項目運營并提出專業(yè)建議和思路。

分布式Barrier，直接看代碼好了：

package curator.barrier;

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.apache.curator.RetryPolicy;
import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.CuratorFrameworkFactory;
import org.apache.curator.framework.recipes.barriers.DistributedBarrier;
import org.apache.curator.retry.ExponentialBackoffRetry;

public class BarrierDemo {

	public static void main(String[] args) throws Exception {
		final List barriers = new ArrayList(3);
		ExecutorService service = Executors.newCachedThreadPool();

		for (int i = 0; i < 3; i++) {
			Runnable run = new Runnable() {
				public void run() {
					try {
						RetryPolicy retryPolicy = new ExponentialBackoffRetry(
								1000, 3);
						final CuratorFramework client = CuratorFrameworkFactory
								.builder().connectString("127.0.0.1:2181")
								.sessionTimeoutMs(5000)
								.connectionTimeoutMs(10000)
								.retryPolicy(retryPolicy).namespace("text")
								.build();
						client.start();

						DistributedBarrier barrier = new DistributedBarrier(client, "/barrier");
						barriers.add(barrier);
						barrier.setBarrier(); // 設置barrier
						System.out.println(" : setBarrier...");
						barrier.waitOnBarrier();// 等待其他進程移除barrier,此后所有的waitOnBarrier進程都將解除阻塞.
						System.err.println(" : run ing...");
					} catch (Exception e) {
					}
				}
			};
			service.execute(run);
		}
		Thread.currentThread().sleep(5000);
		for (DistributedBarrier b : barriers) {
			b.removeBarrier();
		}
		System.in.read();
	}

}

關于“Curator的分布式Barrier怎么實現”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識，可以關注創(chuàng)新互聯行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點。