Java多线程同步问题及解决方案示例-蒲公英云

Java多线程同步问题及解决方案示例

原创忘是亡心i 2024-10-09 18:00 202阅读 0赞

在Java中，多线程同步主要通过以下几种方式实现：

synchronized关键字：
- 修饰方法：synchronized (object) { }
- 修饰代码块：synchronized (blockLock) { // ... }
wait()和notify()方法：
- 当一个线程需要等待其他线程操作完成时，会调用wait()。
- 如果某个条件满足，就需要唤醒正在等待的线程，调用notify()。
Semaphore（信号量）：
- 用于控制同时访问资源的线程数量。
- 当一个线程需要获取信号量时，如果信号量大于0，则会减1并允许线程进入。

示例：

public class SynchronizedExample {
    private final Object lock = new Object();
    // 使用 synchronized 关键字修饰方法
    public void syncMethod() {
        synchronized (lock) {  // 同步代码块
            System.out.println("Sync Method executing...");  // 执行任务
        }
    }
    // 使用 wait 和 notify 方法实现同步
    public class WaitNotifyExample {
        private final Object lock = new Object();
        private boolean isRunning = true;
        public void waitAndNotify() {
            while (isRunning) {  // 确保线程在运行期间进行操作
                synchronized (lock) {  // 同步代码块
                    if (!isRunning) {  // 当不再需要运行时通知
                        System.out.println("Notifying...");  // 输出通知信息
                        lock.notify();  // 提醒等待的线程
                    }
                }
            }
        }
        public void test() {
            new Thread(() -> syncMethod())).start();
            new Thread(() -> waitAndNotify())).start();
        }
    }
    public class Main {
        public static void main(String[] args) {
            SynchronizedExample example = new SynchronizedExample();
            example.test();  // 测试同步操作
        }
    }
}