zoukankan      html  css  js  c++  java
  • 九、curator recipes之不可重入锁InterProcessSemaphoreMutex

    简介

    recipes的InterProcessSemaphoreMutex是一种不可重入的互斥锁,也就意味着即使是同一个线程也无法在持有锁的情况下再次获得锁,所以需要注意,不可重入的锁很容易在一些情况导致死锁,比如你写了一个递归。

    官方文档:http://curator.apache.org/curator-recipes/shared-lock.html

    javaDoc:http://curator.apache.org/curator-recipes/shared-lock.html

    代码示例

    import org.apache.curator.framework.CuratorFramework;
    import org.apache.curator.framework.CuratorFrameworkFactory;
    import org.apache.curator.framework.recipes.locks.InterProcessSemaphoreMutex;
    import org.apache.curator.retry.ExponentialBackoffRetry;
    
    public class SemaphoreMutexDemo {
        private static CuratorFramework client = CuratorFrameworkFactory.newClient("localhost:2181", new ExponentialBackoffRetry(3000, 3));
        private static String path = "/locks/semaphore/0001";
        static {
            client.start();
        }
    
        public static void main(String[] args) throws Exception {
            startThread0();
            Thread.sleep(10);
            startThread1();
            Thread.sleep(50000);
            client.close();
        }
    
        private static void startThread0() {
            new Thread(() -> {
                InterProcessSemaphoreMutex lock = new InterProcessSemaphoreMutex(client, path);
                try {
                    System.out.println("thread0 acquiring");
                    lock.acquire();
                    System.out.println("thread0 acquired");
                    System.out.println("thread0 sleep for 3s");
                    Thread.sleep(3000);
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    try {
                        lock.release();
                        System.out.println("thread0 release");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    
        private static void startThread1() {
            new Thread(() -> {
                InterProcessSemaphoreMutex lock = new InterProcessSemaphoreMutex(client, path);
                try {
                    System.out.println("thread1 acquiring");
                    lock.acquire();
                    System.out.println("thread1 acquired");
                    System.out.println("thread1 sleep for 3s");
                    Thread.sleep(3000);
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    try {
                        lock.release();
                        System.out.println("thread1 release");
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    }
  • 相关阅读:
    Java正则表达式教程
    神奇3D圣诞树祝广大技术人员圣诞快乐!
    SQL语句:Group By总结
    最全面的笔记本基本硬件参数介绍
    已安装的Flash Player不支持FlexBuilder调试
    模拟火车带你游西藏
    javascript技巧参考
    flex 与asp.net 配合之道
    ‍Android 尺寸和分辨率
    【windows】windows生产力/性能分析工具下载链接归档
  • 原文地址:https://www.cnblogs.com/lay2017/p/10274906.html
Copyright © 2011-2022 走看看