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();
        }
    }
  • 相关阅读:
    maven项目编译漏掉src/main/java下的xml配置文件
    读《架构探险——从零开始写Java Web框架》
    使用generator自动生成Mybatis映射配置文件
    git项目添加.gitigore文件
    git-bash下, 启动sshd
    git-bash.exe参数
    少估了一分, 还算不错
    python常用库
    Linux下python pip手动安装笔记
    python学习笔记
  • 原文地址:https://www.cnblogs.com/lay2017/p/10274906.html
Copyright © 2011-2022 走看看