// Java锁示例代码
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
public class LockExample {
private final Lock lock = new ReentrantLock(); // 创建一个ReentrantLock对象
private int count = 0;
public void increment() {
lock.lock(); // 获取锁
try {
count++;
} finally {
lock.unlock(); // 确保在任何情况下都会释放锁
}
}
public int getCount() {
lock.lock();
try {
return count;
} finally {
lock.unlock();
}
}
public static void main(String[] args) {
LockExample example = new LockExample();
// 模拟多线程环境
Thread t1 = new Thread(() -> {
for (int i = 0; i < 1000; i++) {
example.increment();
}
});
Thread t2 = new Thread(() -> {
for (int i = 0; i < 1000; i++) {
example.increment();
}
});
t1.start();
t2.start();
try {
t1.join();
t2.join();
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("Final count: " + example.getCount()); // 应该输出2000
}
}
Lock接口提供了比内置同步(synchronized)更灵活的锁定机制。ReentrantLock是Lock接口的一个实现,支持重入锁。lock()用于获取锁,unlock()用于释放锁。确保在finally块中调用unlock(),以防止死锁。count变量)的访问是线程安全的。这段代码展示了如何使用ReentrantLock来保护共享资源,避免竞态条件,并确保线程安全。
上一篇:java函数式编程
Laravel PHP 深圳智简公司。版权所有©2023-2043 LaravelPHP 粤ICP备2021048745号-3
Laravel 中文站