Java多线程并发问题：线程安全与锁机制示例

原创系统管理员 2024-10-18 11:00 23阅读 0赞

在Java中，由于共享数据的存在，可能会导致多个线程同时修改数据，从而引发线程安全问题。为了解决这个问题，Java引入了锁（Lock）机制。

以下是一个简单的线程安全与锁机制的示例：

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

public class ThreadSafeExample {
    private Lock lock = new ReentrantLock();

public void threadSafeMethod() {
        // 线程安全操作，这里使用同步块
        lock.lock();
        try {
            // 在这里进行线程安全的代码
            System.out.println("Thread safe operation performed by thread " + Thread.currentThread().getId());
        } finally {
            // 无论是否发生异常，都会解锁锁
            lock.unlock();
        }
    }

public static void main(String[] args) {
        ThreadSafeExample example = new ThreadSafeExample();

Thread thread1 = new Thread(() -> {
            example.threadSafeMethod();
            System.out.println("Finished by thread " + thread1.getId());
        }));

Thread thread2 = new Thread(() -> {
            example.threadSafeMethod();
            System.out.println("Finished by thread " + thread2.getId());
        }));

// 启动线程
        thread1.start();
        thread2.start();

// 等待所有线程执行完毕
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个示例中，我们创建了一个`ThreadSafeExample`类，它有一个同步的锁。然后在`threadSafeMethod`方法中，我们使用`lock()`和`unlock()`来控制对共享数据的访问。

在`main`方法中，我们启动了两个线程去调用这个受保护的方法。这样就保证了即使多个线程同时执行，也不会出现数据不一致的问题。