复制代码代码如下:
importar java.util.concurrent.countdownlatch;
importar java.util.concurrent.executorService;
importar java.util.concurrent.executores;
importar java.util.Concurrent.TimeUnit;
importação com.netflix.curator.retrypolicy;
import com.netflix.curator.framework.curatorframework;
import com.netflix.curator.framework.curatorframeworkfactory;
import com.netflix.curator.framework.recipes.locks.interprocessmutex;
importar com.netflix.curator.retry.exponentialbackoffretry;
classe pública testcuratorlock {
/**
* @param args
* @THOWS INTERRUPEDEXCECTIMENTO
*/
public static void main (string [] args) lança interruptedException {
// TODO Method Stub
Countdownlatch Latch = new Countdownlatch (5);
String zookeeperConnectionString = "localhost: 2181, localhost: 2182, localhost: 2183";
Retropolicia Retrypolicy = New Exponentialbackoffretry (1000, 3);
CuratorFramework Client = CuratorFrameworkFactory.NewClient (
ZookeeperConnectionstring, retrypolicy);
client.start ();
System.out.println ("客户端启动。。。。");
ExecutorService Exec = executores.newcachedthreadpool ();
for (int i = 0; i <5; i ++) {
EXEC.SUBMIT (new MyLock ("Client" + I, Client, Latch));
}
exec.shutdown ();
latch.await ();
System.out.println ("所有任务执行完毕");
client.close ();
System.out.println ("客户端关闭。。。。");
}
classe estática mylock implementa Runnable {
nome de string privado;
Cliente de Curador Curador Privado;
Latcha de contagem regressiva privada;
public mylock (nome da string, cliente do CuratorFramework, CountdownLatch Latch) {
this.name = nome;
this.client = client;
this.latch = latch;
}
public String getName () {
Nome de retorno;
}
public void setName (nome da string) {
this.name = nome;
}
@Override
public void run () {
// TODO Method Stub
InterprocessMutex Lock = new InterprocessMutex (cliente,
"/test_group");
tentar {
if (Lock.acquire (120, TimeUnit.Seconds)) {
tentar {
// Faça algum trabalho dentro da seção crítica aqui
System.out.println ("----------" + this.name
+ "获得资源 ----------");
System.out.println ("----------" + this.name
+ "正在处理资源 ----------");
Thread.sleep (10 * 1000);
System.out.println ("----------" + this.name
+ "资源使用完毕 ----------");
latch.CountDown ();
} finalmente {
Lock.Release ();
System.out.println ("----------" + this.name
+ "释放 ----------");
}
}
} catch (Exceção e) {
// TODO BLOCO DE CAPAGEM AUTOMAGEM
E.PrintStackTrace ();
}
}
}
}