使用Java多线程时的同步问题实例

原创快来打我* 2024-12-13 21:00 38阅读 0赞

在Java多线程中，同步问题主要体现在共享资源访问控制上。这里我们通过一个简单的生产者消费者问题来实例化同步问题。

1. 线程模型：
   - 生产者（Producer）：负责产生产品并将其放入队列。
   - 消费者（Consumer）：从队列中获取产品并消费掉。
   
2. 同步问题实例：
```java
import java.util.concurrent.*;

public class SyncExample {
    private final Queue<String> queue = new ArrayBlockingQueue<>(10);

// 生产者线程
    public void producerThread() {
        while (true) {
            try {
                String product = "Product-" + System.currentTimeMillis();
                System.out.println("Producer produced: " + product);
                queue.put(product);
                Thread.sleep(200); // 间隔一定时间，避免频繁生产
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

// 消费者线程
    public void consumerThread() {
        while (true) {
            try {
                String product = queue.take(); // 从队列中获取产品
                System.out.println("Consumer consumed: " + product);
                Thread.sleep(200); // 间隔一定时间，避免频繁消费
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

public static void main(String[] args) {
        SyncExample example = new SyncExample();

// 创建线程池
        ExecutorService executor = Executors.newFixedThreadPool(2);

// 启动生产者和消费者线程
        executor.submit(example.producerThread());
        executor.submit(example.consumerThread());

// 关闭线程池，释放资源
        executor.shutdown();
    }
}
```

在这个例子中，生产者线程不断地产生产品并将其放入队列。而消费者线程则从队列中取出产品进行消费。

由于队列的容量有限（10），当队列满时，新的产品将无法被加入队列。这就体现了同步问题：在多线程环境下，共享资源访问需要控制，以避免冲突和数据丢失。