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

原创系统管理员 2024-12-08 22:51 10阅读 0赞

在Java的多线程并发编程中，常见的同步问题有很多。这里我将举一个简单的例子——生产者消费者问题。

```java
// 创建共享资源（缓冲区）
final int bufferSize = 10;
int[] queue = new int[bufferSize];

// 创建两个线程角色：生产者和消费者
class Producer extends Thread {
    @Override
    public void run() {
        while (true) { // 模拟无限的生产
            queue[queue.length - 1] = randInt(1, 10)); // 生产一个随机数
            if (queue.length == bufferSize) { // 如果队列满，阻塞生产者线程
                synchronized (Producer.class) {
                    Producer.class.wait();
                }
            } else { // 队列不满，直接写入
                System.arraycopy(queue, 0), 1, queue, 0);
            }
            if (queue[0] == randInt(1, 10))) { // 如果队首的数等于随机数，生产结束
                break;
            }
        }
    }
}

class Consumer extends Thread {
    @Override
    public void run() {
        while (true) { // 模拟无限的消费
            if (queue[0] != randInt(1, 10))) { // 如果队首的数不等于随机数，消费结束
                break;
            }
            System.out.println("Consumed: " + queue[0])); // 打印出消费的元素
            queue[0] = 0; // 元素移动到队尾
        }
    }
}

// 创建生产者和消费者线程对象
Producer producer = new Producer();
Consumer consumer = new Consumer();

// 启动生产者线程
producer.start();

// 同步启动消费者线程（保证在生产者开始之前，消费者已经准备好了）
try {
    consumer.start();
} catch (Exception e) {
    System.out.println("Error starting consumer: " + e.getMessage());
}

```
这个例子展示了同步问题的一个常见场景。生产者和消费者通过共享资源进行交互，而这种同步方式可能导致线程阻塞或数据一致性问题。