org.apache.accumulo.server.zookeeper.ZooLock.tryLock()方法的使用及代码示例

转载 作者：知者 更新时间：2024-03-14 05:11:31 25 4

private void getZooLock(HostAndPort addr) throws KeeperException, InterruptedException {
 String path = ZooUtil.getRoot(getInstance()) + Constants.ZGC_LOCK;
 LockWatcher lockWatcher = new LockWatcher() {
  @Override
  public void lostLock(LockLossReason reason) {
   Halt.halt("GC lock in zookeeper lost (reason = " + reason + "), exiting!", 1);
  }
  @Override
  public void unableToMonitorLockNode(final Throwable e) {
   // ACCUMULO-3651 Level changed to error and FATAL added to message for slf4j compatibility
   Halt.halt(-1, new Runnable() {
    @Override
    public void run() {
     log.error("FATAL: No longer able to monitor lock node ", e);
    }
   });
  }
 };
 while (true) {
  lock = new ZooLock(path);
  if (lock.tryLock(lockWatcher,
    new ServerServices(addr.toString(), Service.GC_CLIENT).toString().getBytes())) {
   log.debug("Got GC ZooKeeper lock");
   return;
  }
  log.debug("Failed to get GC ZooKeeper lock, will retry");
  sleepUninterruptibly(1, TimeUnit.SECONDS);
 }
}

zoo.putPersistentData(zPath, new byte[0], NodeExistsPolicy.SKIP);
if (tabletServerLock.tryLock(lw, lockContent)) {
 log.debug("Obtained tablet server lock " + tabletServerLock.getLockPath());
 return;

private void getZooLock(InetSocketAddress addr) throws KeeperException, InterruptedException {
 String address = AddressUtil.toString(addr);
 String path = ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZGC_LOCK;
 LockWatcher lockWatcher = new LockWatcher() {
  public void lostLock(LockLossReason reason) {
   Halt.halt("GC lock in zookeeper lost (reason = " + reason + "), exiting!");
  }
  @Override
  public void unableToMonitorLockNode(final Throwable e) {
   Halt.halt(-1, new Runnable() {
    @Override
    public void run() {
     log.fatal("No longer able to monitor lock node ", e);
    }
   });
  }
 };
 while (true) {
  lock = new ZooLock(path);
  if (lock.tryLock(lockWatcher, new ServerServices(address, Service.GC_CLIENT).toString().getBytes(UTF_8))) {
   break;
  }
  UtilWaitThread.sleep(1000);
 }
}

zoo.putPersistentData(zPath, new byte[0], NodeExistsPolicy.SKIP);
if (tabletServerLock.tryLock(lw, lockContent)) {
 log.debug("Obtained tablet server lock " + tabletServerLock.getLockPath());
 lockID = tabletServerLock.getLockID()

if (zlock.tryLock(lw, lockContent)) {
 log.debug("Obtained tablet server lock " + zlock.getLockPath());

zoo.putPersistentData(zPath, new byte[0], NodeExistsPolicy.OVERWRITE);
ZooLock zl = new ZooLock(zPath);
boolean gotLock = zl.tryLock(new LockWatcher() {

25 4 0

• java - tryLock 未释放的资源

  以下代码已被 Fortify 标记为违规(锁的“未释放资源”) try { if (lock.tryLock(1, TimeUnit.SECONDS)) { try { //d

• iphone - [CFXPreferencesSearchListSource tryLock]

  我正在实现 ShareKit，到目前为止在 iOS5.1 和 6.0 上运行良好，但是 5.0 在模拟器中给我带来了一些问题。 每当我执行操作表并离开程序(例如在浏览器中启动 Facebook)时，我

• tryLock 上的 Java IllegalMonitorStateException

  我想知道是否有人可以帮助我。我是并发编程的新手，我有以下代码，有时会给我一个 IllegalMonitorStateException 作为当前不拥有锁的线程正在尝试解锁。 我在 OTN 论坛上被告知

• java - Hazelcast Trylock 和多次通话

  我遇到了以下问题: 我们有一个包含两个步骤(s1 和s2)的多部分流程P。该过程已实现，在 s1 中获取了一个锁 - 但未释放。在 s2 中再次需要锁(？)并且在 s2 完成后，再次释放锁。 来自do

• java - tryLock 方法 - 非阻塞方法？

  tryLock方法的文档说它是一个非阻塞方法 这允许您获得/获取锁(如果在调用该方法时可能的话)。 但我想知道:如何才能在获得锁的同时保证 你的方法 (tryLock) 是非阻塞的？!获得锁意味着你是

• java - lock.tryLock() 线程安全吗？

  我尝试了使用同步、lock.lock()和lock.tryLock()的线程竞赛程序，我发现使用同步和lock.lock()工作得很好，但lock.tryLock()本身不是线程安全的。此方法无法获取

• java - 可重入 tryLock() 在多线程环境中不加锁

  这是关于可重入锁中的 tryLock() 方法。我正在运行下面的示例代码。我知道这段代码会陷入死锁。 import java.util.concurrent.locks.ReentrantLock;

• c - 调用 trylock() 后解锁互斥量

  我有一个线程服务器，可以添加/附加/读取文件并将数据中继到客户端。 如果正在添加一个文件，则没有其他线程可以追加/读取它。如果正在追加文件，则没有线程可以追加/读取它。如果正在读取文件，则没有其他线程

• java - Lock.tryLock() 的用例

  在 API docs方法tryLock()的Lock接口(interface)，粘贴此代码示例， A typical usage idiom for this method would be: L

• java - ReentrantLock.tryLock() 没有锁定

  我想我只是没有看到一些东西，因为我过去已经让它工作了。 我的锁没有持有独占锁，当创建对象的新实例时，tryLock 返回 true 并安排另一个 TimerTask。 public class A {

• java - FileChannel tryLock() 方法是检查锁还是只是破坏锁？

  我有两个进程可能同时访问同一个文件，想实现文件锁定。问题似乎是一个进程是用 java 编写的，另一个是用 C 编写的，并且不清楚在 java 端如何实现低级锁定。该平台是 Solaris 10。我试图

• c# - D3DImage TryLock 失败

  我正在使用 D3DImage 作为我的 WPF 用户控件的一部分。极少数情况下，在渲染时，D3DImage.TryLock 会失败。 到目前为止，我还没有找到任何关于 D3D.TryLock 为什么会

• Android GC和AudioTrack，GC线程卡在dlmalloc_inspect_all和AudioTrack卡住..tryLock

  快速背景: app是一个音频播放器，ffmpeg编译为native共享对象用于解码，单独的native library编译为共享对象用于音频处理，AudioTrack用于输出处理后的音频。所有音频功能

• qt - 非阻塞循环 {while( QMutex::trylock() );} 如何工作？

  在 Qt 文档中关于 QMutex据说: (...) When you call lock() in a thread, other threads that try to call lock() i

• c - 在 EOWNERDEAD 状态互斥锁上的 Trylock

  当我在前任所有者死后尝试使用“trylock”锁定互斥锁时，我发现了意外行为 无需解锁。 第一个使用 'trylock' 的进程按预期获得 EOWNERDEAD 状态，因此使用 'unlock' 函数

• java - FileChannel.tryLock 有时会抛出 AccessDeniedException

  我编写了一个小方法，用于告诉我应用程序的另一个实例是否已在运行。我知道有很多方法可以查明另一个实例是否正在运行，但我选择了这个。我正在创建一个空文件并在应用程序实例期间保持锁定状态。如果另一个实例正在

• java - JMM 和 trylock 的不良使用

  对 trylock 的不当使用 T1 T2 x = 42; while (

• java - 为什么 FileChannel.tryLock 不阻止跨多个进程的访问？

  这个问题已经有答案了: 已关闭10 年前。 Possible Duplicate: Problem with Java file locking mechanism (FileLock etc) 在下

• java - tryLock 功能不适用于 .text 文件

  如果我手动打开 .txt 文件，然后执行代码来检查文件是否打开。总是说文件未打开。但相同的代码对于任何 MS Office(.doc、.xls、.ppt)都可以按预期工作。 这是代码片段:

• java - tryLock 方法调用是否进入 try block ？

  ReentrantReadWriteLock.ReadLock ReentrantReadWriteLock.WriteLock 对于上面的两个类，我是这样调用锁的吗 try { readL