java线程锁

// Java线程锁示例代码

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

public class ThreadLockExample {
    private final Lock lock = new ReentrantLock(); // 创建一个可重入锁
    private int count = 0;

    public void increment() {
        lock.lock(); // 获取锁
        try {
            count++;
        } finally {
            lock.unlock(); // 确保在try块执行完毕后释放锁
        }
    }

    public int getCount() {
        return count;
    }

    public static void main(String[] args) throws InterruptedException {
        ThreadLockExample example = new ThreadLockExample();

        // 创建多个线程来模拟并发访问
        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();

        t1.join();
        t2.join();

        System.out.println("Final count: " + example.getCount()); // 应该输出2000
    }
}

解释说明：

1. ReentrantLock：这是一个可重入的互斥锁，它可以替代内置的同步机制（synchronized）。它提供了更灵活的锁控制。
2. lock.lock() 和 lock.unlock()：在操作共享资源时，必须先获取锁，操作完成后要释放锁。使用try-finally块确保即使发生异常也能正确释放锁。
3. 线程安全：通过锁机制，保证了多个线程同时访问共享资源（如count变量）时不会产生竞争条件，从而保证了数据的一致性。