Java多线程同步问题: Lock, Synchronized 和 ThreadLocal 组件使用示例

原创偏执的太偏执、 2024-09-11 21:09 17阅读 0赞

在Java多线程编程中，Lock、Synchronized和ThreadLocal是三种常用的同步工具。下面我会分别给出它们的使用示例。

1. Lock (AbstractLock接口及实现类)

- ReentrantLock: 这是最常用的锁实现，提供了公平性和可重入性。
   
   ```java
   import java.util.concurrent.locks.ReentrantLock;

public class LockDemo {
       private final ReentrantLock lock = new ReentrantLock();

public void method() throws InterruptedException {
           // 获取锁
           lock.lock();
           try {
               // 线程执行代码
               System.out.println("Method is running by thread " + Thread.currentThread().getName());
           } finally {
               // 无论是否抛出异常，最后都需要释放锁
               lock.unlock();
           }
       }

public static void main(String[] args) {
           LockDemo demo = new LockDemo();
           new Thread(() -> demo.method())).start(); // 启动新线程执行method方法
       }
   }
   ```

2. Synchronized (Class及方法)

- 使用synchronized修饰的类、方法或代码块。
   
   ```java
   class SynchronizedDemo {
       private int count = 0;

public synchronized void increment() {
           count++;
           System.out.println("Counter incremented to " + count);
       }

public static void main(String[] args) {
           SynchronizedDemo demo = new SynchronizedDemo();

// 同步执行增加计数器的操作
           new Thread(() -> demo.increment())).start();
       }
   }
   ```

3. ThreadLocal (ThreadLocal类)

- ThreadLocal用于在多线程环境中为每个线程提供独立的变量副本。
   
   ```java
   class ThreadLocalDemo {
       private static ThreadLocal<Integer> counter = new ThreadLocal<>();

public void incrementCounter() {
           // 获取当前线程的counter副本
           Integer count = counter.get();
           if (count == null) {
               // 如果首次获取，初始化为1
               count = 1;
               counter.set(count);
           } else {
               // 如果已存在，则将其加一
               count++;
               counter.set(count);
           }
           System.out.println("Counter incremented to " + count);
       }

public static void main(String[] args) {
           ThreadLocalDemo demo = new ThreadLocalDemo();

// 创建两个新线程并执行增加计数器的操作
           new Thread(() -> demo.incrementCounter())).start();
           new Thread(() -> demo.incrementCounter())).start();
       }
   }
   ```

以上就是Java多线程同步中Lock、Synchronized和ThreadLocal的使用示例。