并发编程中，Java多线程同步问题实例

原创心已赠人 2024-09-16 06:04 100阅读 0赞

在Java的多线程编程中，同步问题是经常会遇到的。下面我将以一个简单实例来展示如何处理这类问题。

假设我们有一个简单的生产者（Producer）和消费者（Consumer）模型：

```java
// 生产者类
public class Producer {
    private final Object lock = new Object();

public void produce() {
        lock synchronized (lock) {
            try {
                // 模拟生产任务
                Thread.sleep(1000);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            
            // 在线程安全的环境下唤醒消费者
            lock.notifyAll();
        }
    }
}

// 消费者类
public class Consumer {
    private final Object lock = new Object();

public void consume() {
        lock synchronized (lock) {
            try {
                // 等待生产者生产任务
                lock.wait();
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            
            // 消费任务完成后打印信息
            System.out.println("Consumed task successfully!");
        }
    }
}

// 主程序
public class Main {
    public static void main(String[] args) {
        Producer producer = new Producer();
        Consumer consumer = new Consumer();

// 启动生产者和消费者
        Thread producerThread = new Thread(producer::produce);
        Thread consumerThread = new Thread(consumer::consume);
        
        producerThread.start();  // 开始生产任务
        consumerThread.start();    // 开始消费任务

// 等待生产者和消费者完成任务
        try {
            producerThread.join();
            consumerThread.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}
```

在这个例子中，我们通过锁（`Object lock = new Object();`）来实现线程同步。当一个线程试图获取锁并执行任务时，其他等待获取锁的线程会阻塞，直到锁定的线程释放锁。

这种同步方式在Java多线程编程中非常常见，可以帮助确保线程安全和正确的通信顺序。