并发挑战：Java多线程环境下同步与互斥问题实例-蒲公英云

并发挑战：Java多线程环境下同步与互斥问题实例

原创小咪咪 2024-12-11 02:00 111阅读 0赞

在Java多线程环境中，同步和互斥是两个常见的并发控制问题。

例子1：互斥锁（Synchronized）

public class Counter {
    private int count = 0;
    public synchronized void increment() {
        count++;
        notifyAll(); // 唤醒所有等待的线程
    }
    public synchronized void decrement() {
        count--;
        if (count == 0) {
            notifyAll(); // 唤醒所有等待的线程
        }
    }
    public int getCount() {
        return count;
    }
}

在这个例子中，increment和decrement方法被声明为synchronized。这使得在同一时间只有一个线程能够访问这些方法，从而实现了互斥。

例子2：同步块（Synchronized Block）

public class MutexExample {
    private Object lock = new Object();
    public void criticalSection() {
        synchronized (lock) { // 同步块
            // 这里是线程安全的代码
        }
    }
    public static void main(String[] args) {
        MutexExample example = new MutexExample();
        Thread thread1 = new Thread(() -> {
            example.criticalSection(); // 访问同步代码
        }));
        Thread thread2 = new Thread(() -> {
            example.criticalSection(); // 访问同步代码
        }));
        thread1.start();
        thread2.start();
        try {
            thread1.join();
            thread2.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}