import org.apache.curator.framework.CuratorFramework;
import org.apache.curator.framework.recipes.locks.InterProcessMutex;
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class DistributedLockDemo {
    private final CuratorFramework client;
    
    public DistributedLockDemo(CuratorFramework client) {
        this.client = client;
    }
    
    public void exclusiveLockDemo() {
        InterProcessMutex lock = new InterProcessMutex(client, "/locks/exclusive");
        
        try {
            // 获取锁，设置超时时间
            if (lock.acquire(10, TimeUnit.SECONDS)) {
                log.info("获取锁成功，执行业务逻辑");
                // 模拟业务处理
                Thread.sleep(1000);
            }
        } catch (Exception e) {
            log.error("获取锁失败", e);
        } finally {
            try {
                lock.release();
                log.info("释放锁成功");
            } catch (Exception e) {
                log.error("释放锁失败", e);
            }
        }
    }
}