怎样写分布式锁,用Java?
时间: 2023-01-30 19:27:01 浏览: 137
我们可以使用 Java 并发包中的 Lock 接口实现分布式锁。具体来说,我们可以使用实现了 Lock 接口的类,如 ReentrantLock 或者读写锁 ReadWriteLock。
使用这些类的基本方法如下:
1. 获取锁: 在调用 lock() 方法时,如果锁可用,则获取锁。
2. 释放锁: 在调用 unlock() 方法时,释放锁。
下面是一个使用 ReentrantLock 的例子:
```
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class Counter {
private int count;
private Lock lock = new ReentrantLock();
public void increment() {
lock.lock();
try {
count++;
} finally {
lock.unlock();
}
}
}
```
这段代码使用了 try-finally 块来确保在任何情况下都能够释放锁。
使用 ReadWriteLock 的例子如下:
```
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReadWriteLock;
import java.util.concurrent.locks.ReentrantReadWriteLock;
public class Data {
private final ReadWriteLock rwlock = new ReentrantReadWriteLock();
private final Lock readLock = rwlock.readLock();
private final Lock writeLock = rwlock.writeLock();
private int data;
public void set(int data) {
writeLock.lock();
try {
this.data = data;
} finally {
writeLock.unlock();
}
}
public int get() {
readLock.lock();
try {
return data;
} finally {
readLock.unlock();
}
}
}
```
这段代码使用了读写锁来保护数据的读和写操作。
希望这些信息能帮到你!
阅读全文