Java多线程同步问题：锁和条件变量示例

原创落日映苍穹つ 2024-12-08 10:33 102阅读 0赞

在Java中，多线程同步主要通过两种机制实现：锁（Lock）和条件变量（Condition Variable）。

1. 锁（Lock）：
   - `synchronized`关键字用于修饰方法或代码块，这样同一时刻只有一个线程能访问该部分代码。
   - 示例：
     ```java
     // 对对象的引用进行同步
     private Object lockObj = new Object();

public void threadMethod() {
         synchronized (lockObj) { // 同步
             // 执行任务...
             }
     }

public void main() {
         Thread t1 = new Thread(() -> threadMethod()));
         Thread t2 = new Thread(() -> threadMethod()));

t1.start(); // 启动线程t1
         t2.start(); // 启动线程t2

try { // 等待线程全部执行完毕
             t1.join();
             t2.join();
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
     }
     ```

2. 条件变量（Condition Variable）：
   - `java.util.concurrent.Condition`是Java提供的条件变量接口。
   - 使用条件变量通常需要配合锁，通过调用锁的相应方法来设置或查询条件。
   - 示例：
     ```java
     private final Lock lock = new ReentrantLock();
     private final Condition condition = lock.newCondition();

public void threadMethod() {
         try (lock.lock()) { // 获取锁
             // 执行任务...
             if (someCondition) { // 条件满足
                 condition.signalAll(); // 通知所有等待的线程
             }
             // 释放锁
             lock.unlock();
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
     }

public void main() {
         Thread t1 = new Thread(() -> threadMethod()));
         Thread t2 = new Thread(() -> threadMethod()));

t1.start(); // 启动线程t1
         t2.start(); // 启动线程t2

try { // 等待线程全部执行完毕
             t1.join();
             t2.join();
         } catch (InterruptedException e) {
             e.printStackTrace();
         }
     }
     ```

以上就是Java中锁和条件变量的简单示例。