本文整理了Java中org.apache.samza.zk.ZkProcessorLatch类的一些代码示例，展示了ZkProcessorLatch类的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。ZkProcessorLatch类的具体详情如下：
包路径：org.apache.samza.zk.ZkProcessorLatch
类名称：ZkProcessorLatch

ZkProcessorLatch介绍

暂无

代码示例

代码示例来源：origin: apache/samza

@Override
public Latch getLatch(int size, String latchId) {
 return new ZkProcessorLatch(size, latchId, processorIdStr, zkUtils);
}

代码示例来源：origin: apache/samza

@Override
 public void run() {
  ZkUtils zkUtils = getZkUtilsWithNewClient(participantId);
  zkUtils.connect();
  ZkProcessorLatch latch = new ZkProcessorLatch(
    latchSize, latchId, participantId, zkUtils);
  latch.countDown();
  try {
   latch.await(30, TimeUnit.SECONDS);
  } catch (Exception e) {
   Assert.fail(String.format("Threw an exception while waiting for latch completion in %s! %s",
     participantId, e.getLocalizedMessage()));
  } finally {
   zkUtils.close();
  }
 }
};

代码示例来源：origin: org.apache.samza/samza-core

@Override
public Latch getLatch(int size, String latchId) {
 return new ZkProcessorLatch(size, latchId, processorIdStr, zkUtils);
}

代码示例来源：origin: org.apache.samza/samza-core_2.10

@Override
public Latch getLatch(int size, String latchId) {
 return new ZkProcessorLatch(size, latchId, processorIdStr, zkUtils);
}

代码示例来源：origin: org.apache.samza/samza-core_2.12

@Override
public Latch getLatch(int size, String latchId) {
 return new ZkProcessorLatch(size, latchId, processorIdStr, zkUtils);
}

代码示例来源：origin: org.apache.samza/samza-core_2.11

@Override
public Latch getLatch(int size, String latchId) {
 return new ZkProcessorLatch(size, latchId, processorIdStr, zkUtils);
}

代码示例来源：origin: apache/samza

@Test
public void testLatchExpires() {
 final String latchId = "testLatchExpires";
 final int latchSize = 3;
 Latch latch = new ZkProcessorLatch(latchSize, latchId, "test", testZkUtils);
 try {
  latch.countDown();
  latch.await(5, TimeUnit.SECONDS);
 } catch (TimeoutException e) {
  // expected
 } catch (Exception e) {
  Assert.fail(String.format("Expected only TimeoutException! Received %s", e));
 }
}
private ZkUtils getZkUtilsWithNewClient(String processorId) {

代码示例来源：origin: apache/samza

ZkUtils zkUtils = getZkUtilsWithNewClient(participant1);
zkUtils.connect();
Latch latch = new ZkProcessorLatch(latchSize, latchId, participant1, zkUtils);