并发控制：Java的synchronized和lock使用示例

原创浅浅的花香味﹌ 2024-11-12 20:09 21阅读 0赞

在Java中，`synchronized`和`Lock`都是用来实现并发控制的机制，它们可以帮助我们管理多个线程对共享资源的访问，以防止数据不一致和竞态条件。

### synchronized`synchronized`是Java内置的同步机制，可以用来修饰方法或者代码块。当一个线程访问一个对象的`synchronized`方法或者代码块时，它将获得该对象的锁，其他线程将无法访问该对象的任何`synchronized`方法或代码块，直到当前线程释放锁。

**使用示例：**

```javapublic class Counter {
 private int count =0;

// synchronized修饰方法 public synchronized void increment() {
 count++;
 }

public synchronized int getCount() {
 return count;
 }
}

// 使用Counter counter = new Counter();
Thread t1 = new Thread(() -> {
 for (int i =0; i <1000; i++) {
 counter.increment();
 }
});
Thread t2 = new Thread(() -> {
 for (int i =0; i <1000; i++) {
 counter.increment();
 }
});
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(counter.getCount());
```### Lock`Lock`是Java并发包`java.util.concurrent.locks`中提供的一个接口，提供了比`synchronized`更灵活的锁定机制。常用的实现类有`ReentrantLock`。

**使用示例：**

```javaimport java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;

public class Counter {
 private final Lock lock = new ReentrantLock();
 private int count =0;

// 使用Lock public void increment() {
lock.lock();
 try {
 count++;
} finally {
lock.unlock();
 }
 }

public int getCount() {
lock.lock();
 try {
 return count;
} finally {
lock.unlock();
 }
 }
}

// 使用Counter counter = new Counter();
Thread t1 = new Thread(() -> {
 for (int i =0; i <1000; i++) {
 counter.increment();
 }
});
Thread t2 = new Thread(() -> {
 for (int i =0; i <1000; i++) {
 counter.increment();
 }
});
t1.start();
t2.start();
t1.join();
t2.join();
System.out.println(counter.getCount());
```在`Lock`的使用中，我们通过`lock()`方法获取锁，`unlock()`方法释放锁。`try-finally`结构确保了即使在发生异常的情况下，锁也能被正确释放，这是`synchronized`所不具备的。

`Lock`还提供了其他高级功能，比如尝试非阻塞获取锁（`tryLock()`）、可中断的锁获取（`lockInterruptibly()`）以及支持公平性（`ReentrantLock`的构造函数可以指定是否是公平锁）等。这些特性使得`Lock`在复杂的并发场景下更加灵活和强大。